This is an automated email from the ASF dual-hosted git repository.
jscheffl pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 3c107a4e6f5 Fix pytests for Edge Worker in backcompat tests (#43384)
3c107a4e6f5 is described below
commit 3c107a4e6f5244067ea47ee2674030b4e09c08d5
Author: Jens Scheffler <[email protected]>
AuthorDate: Fri Oct 25 21:27:54 2024 +0200
Fix pytests for Edge Worker in backcompat tests (#43384)
---
providers/tests/edge/cli/test_edge_command.py | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/providers/tests/edge/cli/test_edge_command.py
b/providers/tests/edge/cli/test_edge_command.py
index 6b31db4c8d2..b7a5e3ae3aa 100644
--- a/providers/tests/edge/cli/test_edge_command.py
+++ b/providers/tests/edge/cli/test_edge_command.py
@@ -203,7 +203,9 @@ class TestEdgeWorkerCli:
job = worker_with_job.jobs[0]
job.process.generated_returncode = None
job.logfile.write_text("some log content")
- with conf_vars({("edge", "api_url"): "https://mock.server"}):
+ with conf_vars(
+ {("edge", "api_url"): "https://mock.server";, ("edge",
"push_log_chunk_size"): "524288"}
+ ):
worker_with_job.check_running_jobs()
assert len(worker_with_job.jobs) == 1
mock_push_logs.assert_called_once_with(
@@ -218,7 +220,9 @@ class TestEdgeWorkerCli:
job.logfile.write_text("hello ")
job.logsize = job.logfile.stat().st_size
job.logfile.write_text("hello world")
- with conf_vars({("edge", "api_url"): "https://mock.server"}):
+ with conf_vars(
+ {("edge", "api_url"): "https://mock.server";, ("edge",
"push_log_chunk_size"): "524288"}
+ ):
worker_with_job.check_running_jobs()
assert len(worker_with_job.jobs) == 1
mock_push_logs.assert_called_once_with(
