股票买卖最佳时机leetcode airflow plus:使用简单类型界面的ApacheAirflow外观

股票买卖最佳时机leetcode气流加Facade over Airflow提供了一个简单的类型化界面。简单的表达式运算符定义更好的可组合性大大改进了单元测试和调试。简单类型运算符可以通过实施Operator协议在Airflow Plus中定义Operator。通过将它们变成数据类来支持极简代码。

@dataclass

HelloWorldOperator ( Operator ):

• task_id: str

• msg: str = 'Hello World!'

执行方法:

def execute(self, dag_context: DAGContext):

    print(self.msg)

    print(dag_context.ds)

op = HelloWorldOperator(task_id='test_op')

op.test()