Skip to content

Attributes

Classes

brickflow_plugins.airflow.operators.native_operators.BashOperatorModifier()

Bases: OperatorModifier

Source code in brickflow_plugins/airflow/operators/__init__.py 
46
47
def __init__(self):
    self._next_handler: Optional[AbstractOperatorModifier] = None

Functions

modify(operator: BashOperator, task: Task, workflow: Workflow) -> Optional[BashOperator]

Source code in brickflow_plugins/airflow/operators/native_operators.py 
88
89
90
91
92
93
94
95
@check_if(BashOperator)
def modify(
    self, operator: BashOperator, task: Task, workflow: Workflow
) -> Optional["BashOperator"]:
    f = types.MethodType(_bash_execute, operator)
    operator.execute = f
    operator.on_kill = _bash_empty_on_kill
    return operator

brickflow_plugins.airflow.operators.native_operators.BranchPythonOperatorModifier()

Bases: OperatorModifier

Source code in brickflow_plugins/airflow/operators/__init__.py 
46
47
def __init__(self):
    self._next_handler: Optional[AbstractOperatorModifier] = None

Functions

modify(operator: BranchPythonOperator, task: Task, workflow: Workflow) -> Optional[BranchPythonOperator]

Source code in brickflow_plugins/airflow/operators/native_operators.py 
 99
100
101
102
103
104
105
@check_if(BranchPythonOperator)
def modify(
    self, operator: BranchPythonOperator, task: Task, workflow: Workflow
) -> Optional["BranchPythonOperator"]:
    f = types.MethodType(_skip_all_except, operator)
    operator.skip_all_except = f
    return operator

brickflow_plugins.airflow.operators.native_operators.ShortCircuitOperatorModifier()

Bases: OperatorModifier

Source code in brickflow_plugins/airflow/operators/__init__.py 
46
47
def __init__(self):
    self._next_handler: Optional[AbstractOperatorModifier] = None

Functions

modify(operator: ShortCircuitOperator, task: Task, workflow: Workflow) -> Optional[ShortCircuitOperator]

Source code in brickflow_plugins/airflow/operators/native_operators.py 
109
110
111
112
113
114
115
@check_if(ShortCircuitOperator)
def modify(
    self, operator: ShortCircuitOperator, task: Task, workflow: Workflow
) -> Optional["ShortCircuitOperator"]:
    f = types.MethodType(_short_circuit_execute, operator)
    operator.execute = f
    return operator

Functions