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, handling both local and remote execution modes for different task types. This method orchestrates the task execution, including serialization, resource creation, and monitoring until completion.

Parameters

Name	Type	Description
kwargs	Any	Arbitrary keyword arguments representing the inputs to the task. These inputs are converted from native Python types to a format suitable for task execution.

Returns

Type	Description
Any	The output of the executed task, which can be any type depending on the task's definition.

---