I want to enforce max_active_tis_per_dagrun=1
in a subclassed operator.
Tried these approaches:
class BetterKubernetesPodOperator(KubernetesPodOperator):
def __init__(self, **kwargs) -> None:
_kwargs = kwargs | { "max_active_tis_per_dagrun": 1 }
super().__init__(**_kwargs)
class EvenBetterKubernetesPodOperator(KubernetesPodOperator):
def __init__(self, **kwargs) -> None:
super().__init__(**kwargs)
self.max_active_tis_per_dagrun = 1
However neither seems to work. The only way is to pass it explicitly when instantiating operator:
op = BetterKubernetesPodOperator(task_id="my_task", max_active_tis_per_dagrun=1, ...)
But I don’t want to remember about it every time. How can I have it on subclass?