AsyncConnectorExecutorMixin
This mixin class is used to run the connector task locally, and it's only used for local execution. Task should inherit from this class if the task can be run in the connector.
Methods
execute()
async def execute(self, **kwargs) -> Any: ...
Executes the connector task locally by orchestrating the lifecycle of the task, including code bundling, input serialization, and polling for remote resource completion. This method handles the transition between local and remote execution modes and ensures that secrets and logs are correctly managed during the task run.
Parameters
| Name | Type | Description |
|---|---|---|
| kwargs | dict | The keyword arguments representing the input values to be passed to the task for execution. |
Returns
| Type | Description |
|---|---|
Any | The native Python representation of the task outputs, typically returned as a tuple of values or a single value depending on the task interface. |