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 7fe9b09 commit abe9851Copy full SHA for abe9851
airbyte-cdk/python/airbyte_cdk/entrypoint.py
@@ -212,7 +212,9 @@ def launch(source: Source, args: List[str]) -> None:
212
source_entrypoint = AirbyteEntrypoint(source)
213
parsed_args = source_entrypoint.parse_args(args)
214
for message in source_entrypoint.run(parsed_args):
215
- print(message)
+ # simply printing is creating issues for concurrent CDK as Python uses different two instructions to print: one for the message and
216
+ # the other for the break line. Adding `\n` to the message ensure that both are printed at the same time
217
+ print(f"{message}\n", end="")
218
219
220
def _init_internal_request_filter() -> None:
0 commit comments