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!