1
気流の「所有者」はわかりません。 owerのコメントは "unix usernameを使用することをお勧めします"というタスクの所有者です。 次のコードを書きました。エアフローで正しい所有者タスクを使用する方法を教えてください。
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は、2016年7月20日をTASKID" コマンドを使用し、私は、 ... {} bash_operator.py:77 INFOをいくつかのエラーを得ました - put：許可が拒否されました：user = airflow、 ....
私の仕事は「最大」ユーザーで実行されていましたが、apperently、「airflow」ユーザーを使用してテストを実行しました。
「最大」ユーザーを使用してタスクを実行する場合、どうすればよいですか。
こんにちはマックス、あなたの調査のおかげで、私もそれを把握するのに苦労していた。現在、それはあまり直感的ではないと感じています。私はドッカーと一緒に作業しており、気流のフォルダをローカルフォルダにマップしていたので、ルート権限でフォルダを上書きしました。あなたの質問は正しい方向に私を導いた！ – Pixelartist