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()
@classmethod
def execute(
kwargs: Any
) - > Any
Executes the connector task locally by serializing the task template, uploading necessary code bundles or inputs to remote storage, and polling the connector for completion status.
Parameters
| Name | Type | Description |
|---|---|---|
| kwargs | Any | The input arguments to be passed to the task for execution. |
Returns
| Type | Description |
|---|---|
Any | The task execution results, either as a tuple of native Python objects or a single value depending on the task interface. |