airflow-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Anton Mushin <Anton_Mus...@epam.com>
Subject Define folder for task of dag
Date Fri, 11 May 2018 11:20:41 GMT
Hi everyone, 
I need know folder for task of dag.
for example
I have two tasks in dag:
pwd1 = BashOperator(
    task_id='pwd1',
    bash_command='pwd',
    dag=dag)

pwd2 = BashOperator(
    task_id='pwd2',
    bash_command='pwd',
    dag=dag)

as result I have for pwd1:
{bash_operator.py:97} INFO - Output:
{bash_operator.py:101} INFO - /tmp/airflowtmp3u5tdpt_

for pwd2:
{bash_operator.py:97} INFO - Output:
{bash_operator.py:101} INFO - /tmp/airflowtmphiyryxno

Can I get folder name where will be execute dag task? 
in my case,  before run tasks getting /tmp/airflowtmp3u5tdpt_ and  /tmp/airflowtmphiyryxno

Best Regards,
Anton

Mime
View raw message