Spoiler: I'm pretty much a Python noob. I've started writing a plugin, deriving my plugin Task from

PythonCustomizedContainerTask[T]

and

PythonTask[PluginConfig]

. I then started using my plugin in the workflow, which works out fine. Now I would like to apply caching and other usual decorators like requests and limit. How can I achieve this, as I don't have the classic

Task(...)

decorator for my plugin?

class GlueTask(PythonCustomizedContainerTask[T], PythonTask[GlueConfig]):
    # following the usual init

class GlueTaskExecutor(ShimTaskExecutor[GlueTask]):
    def execute_from_model(self, tt: task_models.TaskTemplate, **kwargs) -> typing.Any:
        # my plugin execution code

# usage in workflow
GlueTask(name="testing", task_config=GlueConfig(crawler_name="test-crawler"), container_image="bla",cache=True, cache_version="1.0")()

That

cache

parameters don't throw errors, but also don't do caching.

nice. welcome @Broder Peters

Cool, thanks for the input!