Fix bug when pass thru PCollection is None. For example when a user would like to remove their data input configuration entirely from the job’s configuration.
No changes - bump version to sync with 21.12.0 release.
21.12.0
No changes - bump version to sync with 21.9.0 release.
21.9.0
Add support for calling DirectGKERunner when set in job configuration.
DirectGKERunner
Use newly-added KlioReadFromPubSub and KlioWriteToPubSub transforms instead of native Beam’s transforms.
KlioReadFromPubSub
KlioWriteToPubSub
Limit version of line_profiler as the latest introduced breaking API changes.
line_profiler
Limit google-cloud-pubsub dependency
klioexec now writes runtime config to include in setup.py distribution.
klioexec
setup.py
Reintroduced comparing build to runtime config
Common cli and exec options moved to klio-core
Config pickling - RunConfig is used to set a main-session global variable
RunConfig
Removed worker dependency on effective-klio-job.yaml
Add warning if FnApi is used in a batch job
Initial public release!