[ https://issues.apache.org/jira/browse/AIRFLOW-357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069119#comment-17069119 ]
Daniel Imberman commented on AIRFLOW-357: ----------------------------------------- This issue has been moved to https://github.com/apache/airflow/issues/7930 > How should I run task with owner not shell owner in AIRFLOW > ------------------------------------------------------------ > > Key: AIRFLOW-357 > URL: https://issues.apache.org/jira/browse/AIRFLOW-357 > Project: Apache Airflow > Issue Type: Bug > Affects Versions: 1.7.1 > Reporter: wei.he > Priority: Major > > I dont understand the "owner" in airflow. the comment of ower is "the owner > of the task, using the unix username is recommended". I wrote some the > following code. > Default_args = { > 'owner': 'max', > 'depends_on_past': False, > 'start_date': datetime(2016, 7, 14), > 'email': ['m...@test.com'], > '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 * * *') > task1_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_impclk',owner='max', > bash_command=pigjob_basedata_impclk, > dag=dag) > I used the command "airflow test dagid taskid 2016-07-20" , > But I got a error, > ... {bash_operator.py:77} INFO - put: Permission denied: user=airflow, .... > I thought that my job ran with "max" user, but apperently , ran test using > 'airflow' user . > I hope if I run my task using 'max' user, how should I do. > Thanks -- This message was sent by Atlassian Jira (v8.3.4#803005)