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