我应该如何在气流中使用正确的拥有者任务？

我不了解气流中的“所有者”。 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

我应该如何在气流中使用正确的拥有者任务？

回答

相关问题