jayachandrakasarla commented on code in PR #69597:
URL: https://github.com/apache/airflow/pull/69597#discussion_r3719091638
##########
providers/celery/tests/unit/celery/executors/test_celery_executor.py:
##########
@@ -1147,6 +1147,91 @@ def
test_execute_workload_runs_execute_task_before_airflow_3_3():
assert mock_supervise.call_args.kwargs["log_path"] == "test.log"
[email protected](not AIRFLOW_V_3_0_PLUS, reason="execute_workload is only
used for Airflow 3+")
[email protected](AIRFLOW_V_3_3_PLUS, reason="pre-3.3 compatibility path
only applies before Airflow 3.3")
[email protected](
+ ("config_value", "expected"),
+ [("True", True), ("False", False)],
+)
+def
test_execute_workload_forwards_task_logs_to_stdout_before_airflow_3_3(config_value,
expected):
Review Comment:
Done. Pulled the workload/mock setup into `execute_task_workload_json` and
`mock_celery_app` fixtures shared by all four tests."
--
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]
