We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c495fc2 commit c9ea6d3Copy full SHA for c9ea6d3
airbyte_cdk/test/entrypoint_wrapper.py
@@ -319,7 +319,7 @@ def _run_command(
319
parsed_args = AirbyteEntrypoint.parse_args(args)
320
321
source_entrypoint = AirbyteEntrypoint(source)
322
- messages = []
+ messages: list[str] = []
323
uncaught_exception = None
324
try:
325
for message in source_entrypoint.run(parsed_args):
@@ -334,8 +334,10 @@ def _run_command(
334
captured_logs = log_capture_buffer.getvalue().split("\n")[:-1]
335
336
parent_logger.removeHandler(stream_handler)
337
-
338
- return EntrypointOutput(messages + captured_logs, uncaught_exception=uncaught_exception)
+ return EntrypointOutput(
+ messages=messages + captured_logs,
339
+ uncaught_exception=uncaught_exception,
340
+ )
341
342
343
def discover(
0 commit comments