Path	Lines of Code
dataflow/__init__.py	1
dataflow/conftest.py	679
dataflow/custom-containers/miniconda/main.py	17
dataflow/custom-containers/miniconda/noxfile_config.py	7
dataflow/custom-containers/miniconda/run.yaml	19
dataflow/custom-containers/minimal/main.py	17
dataflow/custom-containers/minimal/noxfile_config.py	7
dataflow/custom-containers/minimal/run.yaml	19
dataflow/custom-containers/ubuntu/main.py	17
dataflow/custom-containers/ubuntu/noxfile_config.py	7
dataflow/custom-containers/ubuntu/run.yaml	19
dataflow/encryption-keys/bigquery_kms_key.py	48
dataflow/encryption-keys/noxfile_config.py	7
dataflow/extensible-templates/dataflow_udf_transform.js	11
dataflow/extensible-templates/noxfile_config.py	6
dataflow/flex-templates/__init__.py	1
dataflow/flex-templates/getting_started/getting_started.py	18
dataflow/flex-templates/pipeline_with_dependencies/main.py	5
dataflow/flex-templates/pipeline_with_dependencies/noxfile_config.py	3
dataflow/flex-templates/pipeline_with_dependencies/pyproject.toml	23
dataflow/flex-templates/pipeline_with_dependencies/setup.py	2
dataflow/flex-templates/pipeline_with_dependencies/src/my_package/__init__.py	1
dataflow/flex-templates/pipeline_with_dependencies/src/my_package/launcher.py	11
dataflow/flex-templates/pipeline_with_dependencies/src/my_package/my_pipeline.py	18
dataflow/flex-templates/pipeline_with_dependencies/src/my_package/my_transforms.py	13
dataflow/flex-templates/pipeline_with_dependencies/src/my_package/utils/__init__.py	1
dataflow/flex-templates/pipeline_with_dependencies/src/my_package/utils/figlet.py	4
dataflow/flex-templates/streaming_beam/__init__.py	1
dataflow/flex-templates/streaming_beam/noxfile_config.py	9
dataflow/flex-templates/streaming_beam/streaming_beam.py	85
dataflow/gemma-flex-template/custom_model_gemma.py	117
dataflow/gemma-flex-template/noxfile_config.py	6
dataflow/gemma/custom_model_gemma.py	75
dataflow/gemma/noxfile_config.py	6
dataflow/gpu-examples/pytorch-minimal/build.yaml	9
dataflow/gpu-examples/pytorch-minimal/main.py	39
dataflow/gpu-examples/pytorch-minimal/noxfile_config.py	8
dataflow/gpu-examples/pytorch-minimal/run.yaml	25
dataflow/gpu-examples/tensorflow-landsat-prime/build.yaml	8
dataflow/gpu-examples/tensorflow-landsat-prime/main.py	197
dataflow/gpu-examples/tensorflow-landsat-prime/noxfile_config.py	6
dataflow/gpu-examples/tensorflow-landsat-prime/run.yaml	29
dataflow/gpu-examples/tensorflow-landsat/build.yaml	8
dataflow/gpu-examples/tensorflow-landsat/main.py	189
dataflow/gpu-examples/tensorflow-landsat/noxfile_config.py	6
dataflow/gpu-examples/tensorflow-landsat/run.yaml	28
dataflow/gpu-examples/tensorflow-minimal/build.yaml	8
dataflow/gpu-examples/tensorflow-minimal/main.py	40
dataflow/gpu-examples/tensorflow-minimal/noxfile_config.py	6
dataflow/gpu-examples/tensorflow-minimal/run.yaml	26
dataflow/run-inference/download_model.py	99
dataflow/run-inference/main.py	86
dataflow/run-inference/noxfile_config.py	7
dataflow/run_template/main.py	58
dataflow/snippets/__init__.py	1
dataflow/snippets/batch_write_storage.py	21
dataflow/snippets/noxfile_config.py	7
dataflow/snippets/read_kafka.py	33
dataflow/snippets/read_kafka_multi_topic.py	37
dataflow/snippets/write_pubsub.py	34