martinzink commented on code in PR #2044:
URL: https://github.com/apache/nifi-minifi-cpp/pull/2044#discussion_r2466576337
##########
extensions/aws/tests/features/steps/s3_server_container.py:
##########
@@ -0,0 +1,62 @@
+import json
+import logging
+
+from minifi_test_framework.containers.container import Container
+from minifi_test_framework.core.helpers import wait_for_condition
+from minifi_test_framework.core.minifi_test_context import MinifiTestContext
+
+
+class S3ServerContainer(Container):
+ def __init__(self, test_context: MinifiTestContext):
+ super().__init__("adobe/s3mock:3.12.0",
f"s3-server-{test_context.scenario_id}", test_context.network)
+ self.environment.append("initialBuckets=test_bucket")
+
+ def deploy(self):
+ super().deploy()
+ finished_str = "Started S3MockApplication"
+ return wait_for_condition(
+ condition=lambda: finished_str in self.get_logs(),
+ timeout_seconds=15,
+ bail_condition=lambda: self.exited,
+ context=None)
+
+ def check_kinesis_server_record_data(self, container_name, record_data):
Review Comment:
since these checks dont seem to fail since I guess not, if these start to
fail we could use them in a wait_for_condition
--
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]
