我應該如何在氣流中使用正確的擁有者任務？

我不瞭解氣流中的「所有者」。 ower的評論是「任務的擁有者，建議使用unix用戶名」。我寫了下面的代碼。我應該如何在氣流中使用正確的擁有者任務？

Default_args = { 
'owner': 'max', 
'depends_on_past': False, 
'start_date': datetime(2016, 7, 14), 
'email': ['[email protected]'], 
'email_on_failure': False, 
'email_on_retry': False, 
'retries': 1, 
'retry_delay': timedelta(minutes=5),

}

dag = DAG('dmp-annalect', default_args=default_args, 
       schedule_interval='30 0 * * *') 

pigjob_basedata = """{local_dir}/src/basedata/basedata.sh > 
{local_dir}/log/basedata/run_log & 
""".format(local_dir=WORKSPACE) 

task1_pigjob_basedata = BashOperator(
task_id='task1_pigjob_basedata',owner='max', 
bash_command=pigjob_basedata , 
dag=dag)

但我用命令「氣流測試dagid任務id 2016年7月20日」，我得到了一些錯誤， ... {} bash_operator.py:77 INFO - 把：拒絕權限：用戶=氣流， ....

我認爲我的工作與「最大」用戶運行，但顯然，使用'氣流'用戶跑測試。

我希望如果我使用'max'用戶運行我的任務，我該怎麼做。

來源

2016-07-22 Max.H

我想出了這個問題。因爲我在/ home/airflow /中設置了AIRFLOW_HOME，所以只有氣流可以訪問這個文件目錄。

來源

2016-07-22 08:57:35

你好馬克斯，感謝您的調查，我也很難找出它。目前感覺不太直觀。由於我正在使用docker並將airflow的文件夾映射到本地文件夾，因此它使用root權限覆蓋了該文件夾。你的問題引導我走向正確的方向！ – Pixelartist

我應該如何在氣流中使用正確的擁有者任務？

回答

相關問題