Skip to content

Commit

Permalink
[airbyte-cdk] add print parameter to flush the print buffer after eac…
Browse files Browse the repository at this point in the history
…h invocation (#37000)
  • Loading branch information
brianjlai committed Apr 11, 2024
1 parent 9ac5233 commit 822d76c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion airbyte-cdk/python/airbyte_cdk/entrypoint.py
Expand Up @@ -235,7 +235,7 @@ def launch(source: Source, args: List[str]) -> None:
for message in source_entrypoint.run(parsed_args):
# simply printing is creating issues for concurrent CDK as Python uses different two instructions to print: one for the message and
# the other for the break line. Adding `\n` to the message ensure that both are printed at the same time
print(f"{message}\n", end="")
print(f"{message}\n", end="", flush=True)


def _init_internal_request_filter() -> None:
Expand Down

0 comments on commit 822d76c

Please sign in to comment.