<#913 Add custom connector app example> Pull reque...
# flyte-github
a
#913 Add custom connector app example Pull request opened by pingsutw Summary • Add a complete example showing how to build and deploy a custom connector • `BatchJobConnector`: an
AsyncConnector
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-sdk