我对气流和使用“xcom_push”和“xcom_pull”功能非常陌生。
我有两个 dags d1 ，其中包含任务 t1 ，第二个 dags d2 包含任务 t2 。
现在我使用以下命令推送 dag d1 中的值：
kwargs['ti'].xcom_push(key='start_date',value=start_date)
kwargs['ti'].xcom_push(key='end_date',value=end_date)
并使用以下命令在 dag d2 中提取相同的 start_date 和 end_date ：
start_date = kwargs['ti'].xcom_pull(dag_id = 'd1', task_ids='t1',key="start_date")
end_date = kwargs['ti'].xcom_pull(dag_id = 'd1', task_ids='t2' , key="end_Date")
但是在 xcom_pull 期间出现“NONETYPE”错误。任何人都可以帮助我如何将 dag d1 中的值提取到 dag d2 中
我有一个 scala 列表
List("Date=2018-02-19","Date=2018-02-25","Date=2018-03-03")
我需要从列表中的每个元素中删除“Date=”，最终结果应该是
List("2018-02-19","2018-02-25","2018-03-03")
谁能建议我任何有效的方法来实现这个？