path	# lines of code
microsite/index.html	102
microsite/css/fonts.css	77
microsite/css/main.css	125
devtools/src/klio_devtools/__init__.py	5
devtools/src/klio_devtools/commands/develop.py	63
devtools/src/klio_devtools/cli.py	60
devtools/MANIFEST.in	10
devtools/setup.py	134
devtools/setup.cfg	9
audio/src/klio_audio/__init__.py	5
audio/src/klio_audio/transforms/audio.py	106
audio/src/klio_audio/transforms/__init__.py	1
audio/src/klio_audio/transforms/_base.py	33
audio/src/klio_audio/transforms/io.py	81
audio/src/klio_audio/decorators.py	149
audio/MANIFEST.in	10
audio/setup.py	136
audio/setup.cfg	12
exec/src/klio_exec/__init__.py	5
exec/src/klio_exec/options.py	38
exec/src/klio_exec/commands/run.py	479
exec/src/klio_exec/commands/utils/__init__.py	1
exec/src/klio_exec/commands/utils/wrappers.py	72
exec/src/klio_exec/commands/utils/plugin_utils.py	44
exec/src/klio_exec/commands/utils/memory_utils.py	47
exec/src/klio_exec/commands/utils/cpu_utils.py	24
exec/src/klio_exec/commands/utils/profile_utils.py	43
exec/src/klio_exec/commands/__init__.py	1
exec/src/klio_exec/commands/audit_steps/base.py	40
exec/src/klio_exec/commands/audit_steps/numpy_broken_blas.py	47
exec/src/klio_exec/commands/audit_steps/multithreaded_tf.py	21
exec/src/klio_exec/commands/audit_steps/__init__.py	1
exec/src/klio_exec/commands/audit_steps/tempfile_usage.py	37
exec/src/klio_exec/commands/stop.py	126
exec/src/klio_exec/commands/profile.py	214
exec/src/klio_exec/commands/audit.py	80
exec/src/klio_exec/cli.py	288
exec/src/klio_exec/runners/evaluators.py	64
exec/src/klio_exec/runners/__init__.py	1
exec/src/klio_exec/runners/gke_direct.py	65
exec/MANIFEST.in	10
exec/setup.py	166
exec/setup.cfg	12
core/src/klio_core/dataflow.py	86
core/src/klio_core/__init__.py	5
core/src/klio_core/config/_io.py	351
core/src/klio_core/config/__init__.py	12
core/src/klio_core/config/_converters.py	92
core/src/klio_core/config/core.py	276
core/src/klio_core/config/_utils.py	86
core/src/klio_core/config/_preprocessing.py	91
core/src/klio_core/variables.py	26
core/src/klio_core/exceptions.py	4
core/src/klio_core/options.py	192
core/src/klio_core/_testing.py	71
core/src/klio_core/utils.py	118
core/src/klio_core/proto/klio.proto	102
core/src/klio_core/proto/v1beta1/klio_pb2.py	1
core/src/klio_core/proto/v1beta1/__init__.py	1
core/src/klio_core/proto/__init__.py	1
core/MANIFEST.in	11
core/setup.py	142
core/setup.cfg	12
cli/src/klio_cli/utils/cli_utils.py	87
cli/src/klio_cli/utils/__init__.py	1
cli/src/klio_cli/utils/stackdriver_utils.py	80
cli/src/klio_cli/utils/multi_line_terminal_writer.py	29
cli/src/klio_cli/utils/docker_utils.py	105
cli/src/klio_cli/utils/config_utils.py	36
cli/src/klio_cli/__init__.py	5
cli/src/klio_cli/options.py	210
cli/src/klio_cli/commands/base.py	136
cli/src/klio_cli/commands/job/run.py	88
cli/src/klio_cli/commands/job/utils/__init__.py	1
cli/src/klio_cli/commands/job/utils/templates/setup.py.tpl	118
cli/src/klio_cli/commands/job/utils/templates/job-requirements.txt.tpl	9
cli/src/klio_cli/commands/job/utils/templates/transforms.py.tpl	34
cli/src/klio_cli/commands/job/utils/templates/README.md.tpl	5
cli/src/klio_cli/commands/job/utils/templates/init.py.tpl	3
cli/src/klio_cli/commands/job/utils/templates/klio-job.yaml.tpl	53
cli/src/klio_cli/commands/job/utils/templates/dockerfile.tpl	39
cli/src/klio_cli/commands/job/utils/templates/transforms-batch.py.tpl	34
cli/src/klio_cli/commands/job/utils/templates/MANIFEST.in.tpl	1
cli/src/klio_cli/commands/job/utils/templates/run.py.tpl	24
cli/src/klio_cli/commands/job/utils/templates/klio-job-batch.yaml.tpl	44
cli/src/klio_cli/commands/job/utils/gcp_setup.py	121
cli/src/klio_cli/commands/job/__init__.py	20
cli/src/klio_cli/commands/job/delete.py	124
cli/src/klio_cli/commands/job/gke.py	345
cli/src/klio_cli/commands/job/verify.py	437
cli/src/klio_cli/commands/job/stop.py	126
cli/src/klio_cli/commands/job/configuration.py	100
cli/src/klio_cli/commands/job/profile.py	168
cli/src/klio_cli/commands/job/audit.py	12
cli/src/klio_cli/commands/job/create.py	635
cli/src/klio_cli/commands/__init__.py	1
cli/src/klio_cli/commands/image/__init__.py	2
cli/src/klio_cli/commands/image/build.py	14
cli/src/klio_cli/commands/message/__init__.py	2
cli/src/klio_cli/commands/message/publish.py	102
cli/src/klio_cli/cli.py	617
cli/MANIFEST.in	13
cli/setup.py	152
cli/setup.cfg	12
lib/src/klio/metrics/base.py	67
lib/src/klio/metrics/client.py	75
lib/src/klio/metrics/dispatcher.py	151
lib/src/klio/metrics/__init__.py	1
lib/src/klio/metrics/shumway.py	104
lib/src/klio/metrics/native.py	70
lib/src/klio/metrics/logger.py	115
lib/src/klio/utils/__init__.py	2
lib/src/klio/utils/_thread_limiter.py	53
lib/src/klio/__init__.py	5
lib/src/klio/transforms/__init__.py	20
lib/src/klio/transforms/_helpers.py	172
lib/src/klio/transforms/_timeout.py	86
lib/src/klio/transforms/helpers.py	418
lib/src/klio/transforms/decorators.py	544
lib/src/klio/transforms/_retry.py	78
lib/src/klio/transforms/core.py	87
lib/src/klio/transforms/_utils.py	55
lib/src/klio/transforms/io.py	286
lib/src/klio/message/serializer.py	71
lib/src/klio/message/__init__.py	1
lib/src/klio/message/exceptions.py	2
lib/src/klio/message/pubsub_message_manager.py	154
lib/MANIFEST.in	11
lib/setup.py	140
lib/setup.cfg	12
integration/read-file-write-file/klio-job.yaml	29
integration/read-file-write-file/run.py	4
integration/read-file-write-file/__init__.py	1
integration/read-file-write-file/MANIFEST.in	1
integration/read-file-write-file/setup.py	59
integration/read-file-write-file/job-requirements.in	3
integration/read-file-write-file/transforms.py	9
integration/read-file/klio-job.yaml	17
integration/read-file/run.py	20
integration/read-file/__init__.py	1
integration/read-file/MANIFEST.in	1
integration/read-file/setup.py	59
integration/read-file/job-requirements.in	3
integration/read-file/transforms.py	9
integration/batch-modular-default/klio-job.yaml	35
integration/batch-modular-default/run.py	17
integration/batch-modular-default/__init__.py	1
integration/batch-modular-default/MANIFEST.in	1
integration/batch-modular-default/setup.py	59
integration/batch-modular-default/job-requirements.in	3
integration/batch-modular-default/transforms.py	8
integration/multi-event-input-batch/klio-job.yaml	31
integration/multi-event-input-batch/run.py	35
integration/multi-event-input-batch/__init__.py	1
integration/multi-event-input-batch/MANIFEST.in	1
integration/multi-event-input-batch/setup.py	59
integration/multi-event-input-batch/job-requirements.in	3
integration/audio-spectrograms/klio-job.yaml	31
integration/audio-spectrograms/run.py	78
integration/audio-spectrograms/__init__.py	1
integration/audio-spectrograms/MANIFEST.in	1
integration/audio-spectrograms/setup.py	59
integration/audio-spectrograms/job-requirements.in	6
integration/audio-spectrograms/transforms.py	83
integration/read-bq-write-bq/klio-job.yaml	45
integration/read-bq-write-bq/run.py	4
integration/read-bq-write-bq/__init__.py	1
integration/read-bq-write-bq/it/before.py	47
integration/read-bq-write-bq/it/__init__.py	1
integration/read-bq-write-bq/it/after.py	21
integration/read-bq-write-bq/it/common.py	13
integration/read-bq-write-bq/MANIFEST.in	1
integration/read-bq-write-bq/setup.py	59
integration/read-bq-write-bq/job-requirements.in	3
integration/read-bq-write-bq/transforms.py	12