Changed thread limiter logging to debug.
Workers will look for klio-job-run-effective.yaml before dropping back to .effective-klio-job.yaml.
klio-job-run-effective.yaml
.effective-klio-job.yaml
Add thread limiting context manager utility (See KEP 2: Thread Management).
Add default thread management to @handle_klio decorator (See KEP 2: Thread Management).
@handle_klio
Partially reverted back to reading config from effective-klio-job.yaml (See PR 147).
effective-klio-job.yaml
Fixed non-Klio -> Klio message parsing.
Fixed calling of to_klio_message in helper transforms.
to_klio_message
Added support for writing an avro file via KlioWriteToAvro
KlioWriteToAvro
Allow for support of empty job_config.data values for the built-in helper filter transforms.
job_config.data
Requires klio-core>=0.2.1 now that dependent changes have been released in new core version
Requires klio-core<0.2.1,>=0.2.0 to prevent useage of 0.2.1 until dependent code is released
Klio lib requires changes not yet released in klio-core
Handling of exceptions yielded by functions/methods decorated with @handle_klio
KlioReadFromBigQuery rewritten as reader + map transform
Limited apache beam dependency to <2.25.0 due to a breaking change
Initial public release!