python執行配置 PythonOp的執行時配置

2021-10-12 11:41:05 字數 1384 閱讀 1102

我找不到任何關於如何使用通過「-c」傳遞的json變數的工作文件,例如回填作業。在

我一直在列印我的python任務**kwargs以找出答案,但我仍然無法確定它。提供_context=true

誰能給我指出正確的方向嗎?在

所以,我想做的是:airflow backfill mydag -c '' -s 2018-12-01 -e 2018-12-12

我有乙隻python:

^$在run_task中,我想訪問override變數:def run_task(*args, **kwargs):

dag_run = kwargs.get('dag_run')

logging.info(kwargs['dag_run'].conf.get('override'))

但是我找不到訪問這個覆蓋變數的方法[2018-12-17 10:07:24,649] error - 'nonetype' object has no attribute 'get'

traceback (most recent call last):

file "/home/daimonie/.local/lib/python3.6/site-packages/airflow/models.py", line 1659, in _run_raw_task

result = task_copy.execute(context=context)

file "/home/daimonie/.local/lib/python3.6/site-packages/airflow/operators/python_operator.py", line 95, in execute

return_value = self.execute_callable()

file "/home/daimonie/.local/lib/python3.6/site-packages/airflow/operators/python_operator.py", line 100, in execute_callable

return self.python_callable(*self.op_args, **self.op_kwargs)

file "/home/daimonie/airflow/dags/dag_scheduled_queries.py", line 65, in run_query

logging.info(kwargs['dag_run'].conf.get('override'))

# `airflow trigger_dag -c`, the key-value pairs will override the existing ones in params.

dag_run_conf_overrides_params=true

donot_pickle引數設定為false。在

本地Python執行遠端伺服器Python指令碼

情景 區域網內一台pc或伺服器 windows或linux 上有一python指令碼,如何執行它?常用的兩種 遠端桌面和xshell遠端連線 那假如想要不通過以上兩種方式的前提下執行它,可行麼?怎麼辦?答案是肯定的 coding utf 8 author lihaizhen date descrip...

Ubuntu vim基本外掛程式配置 Python版

記錄本人簡單vim配置,防止以後重新配置時遺忘。將目錄中的 vimrc 移動到home目錄並重命名為 vimrc 將 vimrc 中的作者頭刪除 安裝vundle外掛程式管理 git clone vim bundle vundle.vim開啟vim,輸入下面指令安裝外掛程式 youcompletem...

如何在LINUX UNIX上執行PYTHON程式

編寫python 程式的方法與 shell 指令碼類似。例如,要編輯乙個名為 try python 的python 程式檔案,輸入如下命令。pico try python 下面輸入一段簡單的 python 來檢查它是否工作。usr bin env python print 2 2 第一行告訴 she...