flytekit.extend.TaskPlugins

class flytekit.extend.TaskPlugins[source]

This is the TaskPlugins factory for task types that are derivative of PythonFunctionTask. Every task that the user wishes to use should be available in this factory. Usage

TaskPlugins.register_pythontask_plugin(config_object_type, plugin_object_type)
# config_object_type is any class that will be passed to the plugin_object as task_config
# Plugin_object_type is a derivative of ``PythonFunctionTask``
__init__()

Initialize self. See help(type(self)) for accurate signature.

Methods

__init__()

Initialize self.

find_pythontask_plugin(plugin_config_type)

Returns a PluginObjectType if found or returns the base PythonFunctionTask

register_pythontask_plugin(…)

Use this method to register a new plugin into Flytekit. Usage ::.