amrapali-kumari commented on issue #29002:
URL: https://github.com/apache/airflow/issues/29002#issuecomment-1408368135
I'm also getting the same issue , whats this command running in if condition
can anyone suggest how should I proceed with this :
[2023-01-30, 09:43:45 UTC] {pod_manager.py:385} INFO - Running command... if
[ -s /airflow/xcom/return.json ]; then cat /airflow/xcom/return.json; else echo
__airflow_xcom_result_empty__; fi
[2023-01-30, 09:43:45 UTC] {pod_manager.py:385} INFO - Running command...
kill -s SIGINT 1
Below is my code
dag = DAG(
dag_id=DAG_NAME,
default_args=DEFAULT_ARGS,
schedule_interval=SCHEDULE_INTERVAL,
max_active_runs=MAX_ACTIVE_RUNS,
catchup=CATCHUP,
)
start = DummyOperator(task_id="start", dag=dag)
print_msg = BashOperator(
task_id="print_msg", bash_command="echo 'I am working fine'", dag=dag
)
task_logger.info("print msg task executed successfully")
t2 = KubernetesPodOperator(
name="docker-testing",
namespace="airflow",
image="test",
cmds=["bash", "-cx"],
arguments=["echo", "Hello world"],
labels={"foo": "bar"},
# in_cluster=in_cluster,
task_id="dry_run_demo",
do_xcom_push=True,
# config_file=config_file,
is_delete_operator_pod=False,
get_logs=True,
dag=dag,
)
task_logger.info("docker class executed successfully")
end = DummyOperator(task_id="end", dag=dag)
start >> print_msg >> t2 >> end
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
