Skip to content

Commit 822d76c

Browse files
authored
[airbyte-cdk] add print parameter to flush the print buffer after each invocation (#37000)
1 parent 9ac5233 commit 822d76c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

airbyte-cdk/python/airbyte_cdk/entrypoint.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,7 @@ def launch(source: Source, args: List[str]) -> None:
235235
for message in source_entrypoint.run(parsed_args):
236236
# simply printing is creating issues for concurrent CDK as Python uses different two instructions to print: one for the message and
237237
# the other for the break line. Adding `\n` to the message ensure that both are printed at the same time
238-
print(f"{message}\n", end="")
238+
print(f"{message}\n", end="", flush=True)
239239

240240

241241
def _init_internal_request_filter() -> None:

0 commit comments

Comments
 (0)