It seems that this temporary folder name can't be got. The folder you saw is a TemporaryFile created to hold your bash command and run it by BashOperator, I think you could have your own working space and run your logic there by simply "cd {your_work_space}; do something". ________________________________ 发件人: Anton Mushin <anton_mus...@epam.com> 发送时间: 2018年5月11日 11:20 收件人: dev@airflow.incubator.apache.org 主题: Define folder for task of dag
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