AsyncConnectorExecutorMixin

Package: flyte.connectors

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()

def execute(
    kwargs,
) -> typing.Any