This is an automated email from the ASF dual-hosted git repository. martinzink pushed a commit to branch MINIFICPP-2711 in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
commit 18c6efafbaaaf81ae1cf7353e67779b93d0c2cd7 Author: Martin Zink <[email protected]> AuthorDate: Fri Feb 6 14:56:05 2026 +0100 review changes --- extensions/gcp/tests/features/steps/fake_gcs_server_container.py | 2 +- extensions/grafana-loki/tests/features/steps/grafana_loki_container.py | 2 +- extensions/kafka/tests/features/steps/kafka_server_container.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/extensions/gcp/tests/features/steps/fake_gcs_server_container.py b/extensions/gcp/tests/features/steps/fake_gcs_server_container.py index b55b7aaff..a9733ba4e 100644 --- a/extensions/gcp/tests/features/steps/fake_gcs_server_container.py +++ b/extensions/gcp/tests/features/steps/fake_gcs_server_container.py @@ -33,7 +33,7 @@ class FakeGcsServerContainer(Container): condition=lambda: finished_str in self.get_logs(), timeout_seconds=30, bail_condition=lambda: self.exited, - context=None) + context=context) @retry_check() def check_google_cloud_storage(self, content): diff --git a/extensions/grafana-loki/tests/features/steps/grafana_loki_container.py b/extensions/grafana-loki/tests/features/steps/grafana_loki_container.py index 8a3e3fc7a..32f1cf1db 100644 --- a/extensions/grafana-loki/tests/features/steps/grafana_loki_container.py +++ b/extensions/grafana-loki/tests/features/steps/grafana_loki_container.py @@ -133,7 +133,7 @@ analytics: condition=lambda: finished_str in self.get_logs(), timeout_seconds=120, bail_condition=lambda: self.exited, - context=None) + context=context) @retry_check() def are_lines_present(self, lines: str, timeout: int, ssl: bool, tenant_id: str = "") -> bool: diff --git a/extensions/kafka/tests/features/steps/kafka_server_container.py b/extensions/kafka/tests/features/steps/kafka_server_container.py index 6a68f9611..30073186f 100644 --- a/extensions/kafka/tests/features/steps/kafka_server_container.py +++ b/extensions/kafka/tests/features/steps/kafka_server_container.py @@ -95,7 +95,7 @@ Client { condition=lambda: finished_str in self.get_logs(), timeout_seconds=60, bail_condition=lambda: self.exited, - context=None) + context=context) def create_topic(self, topic_name: str): (code, output) = self.exec_run(["/bin/sh", "-c", f"/opt/kafka/bin/kafka-topics.sh --create --topic '{topic_name}' --bootstrap-server '{self.container_name}':9092"])
