气流任务意外关键字问题

问题描述

我有一个python运算符。

>>> list(map(asterisk(lambda k,v: k * v),d.items()))
['a','bb']

我已将Provide_context设置为True,因为我需要将数据发送到其他任务。 我有只想传递 params 而不传递 kwargs 的功能。

PythonOperator(
            task_id="getData",python_callable=getData,op_kwargs={
                "params": {
                    "days": 1,"limit": 10
                }
            },provide_context=True,)

我以以下方式运行时遇到错误:

TypeError:getData()得到了意外的关键字参数“ conf”

当我传递** kwargs并从中提取参数时,它可以正常工作,但我不想仅传递kwargs的参数,对此该怎么办?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)