jason810496 opened a new pull request, #69521: URL: https://github.com/apache/airflow/pull/69521
FileTaskHandler._read() returns an itertools.islice stream when resuming a log read via metadata["log_pos"] (introduced in #63531), but _is_logs_stream_like() only recognized chain and generator objects, so the public read() wrapper raised TypeError: Invalid log stream type... Got islice instead whenever a client polled or tailed a running task's logs. (cherry picked from commit 87089a5) -- 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]
