acoustic-carpenter-78188
04/07/2026, 4:58 AMAsyncConnector that simulates an external batch job (create/poll/cancel)
• `BatchJobTask`: a TaskTemplate-based task plugin (same pattern as BigQueryTask)
• `app.py`: deploys the connector as a ConnectorEnvironment
• `main.py`: defines and runs a task against the custom connector
• Fix ConnectorEnvironment to pass --modules arg for custom connector loading
• Change ConnectorEnvironment.type from "Connector" to "connector"
Test plan
• Deploy the connector with python app.py and verify it registers
• Run python main.py and verify the batch job task executes through the connector
• Verify connector logs show create/poll/complete lifecycle
flyteorg/flyte-sdkacoustic-carpenter-78188
04/07/2026, 9:57 PM