exec/src/klio_exec/commands/run.py (8 lines):
	- line 223: # TODO: maybe provide way to allow something besides just "CI"
	- line 387: # TODO: update me to `var.KlioRunner.DIRECT_GKE_RUNNER` once
	- line 419: # TODO: this "tagging by version then processing each version
	- line 440: # TODO: update me to `var.KlioRunner.DIRECT_GKE_RUNNER` once
	- line 456: # TODO this can prob go away if/when we make event_inputs a
	- line 530: # TODO: update me to `var.KlioRunner.DIRECT_GKE_RUNNER` once
	- line 615: # TODO: is this possible?
	- line 622: # TODO: update me to `var.KlioRunner.DIRECT_GKE_RUNNER` once


cli/src/klio_cli/cli.py (8 lines):
	- line 48: # TODO: configure a CLI logger so that it's more pleasing to the user,
	- line 58: # TODO: We can get rid of direct_runner since we have runner
	- line 218: # TODO: make this a click option once draining is supported @lynn
	- line 265: # TODO: make this a click option once draining is supported @lynn
	- line 294: # TODO validate name for apache beam/dataflow & python imports/packaging
	- line 313: # TODO: grab default project from gcloud config or env var, and only
	- line 578: # TODO: same as in exec/src/klio_exec/cli.py; move to core @lynn
	- line 759: # TODO: make sure this is moved into KlioConfig


cli/src/klio_cli/commands/job/create.py (7 lines):
	- line 70: # TODO: add a boolean flag to cli.create_job command to force-recreate
	- line 82: # TODO: wrap the writing of a file in a `try`/`except`. If there is
	- line 164: # TODO: add validation that the image string is in the format of
	- line 267: # TODO: increase abstraction - we generate some defaults more than once
	- line 429: # TODO should this even be an option? run-job will break if so.
	- line 430: # TODO: figure out if we should expose `experiments` to the user, or
	- line 472: # TODO: remove support for providing a dockerfile and docker image


lib/src/klio/transforms/helpers.py (6 lines):
	- line 227: # TODO: figure out how to support multiple outputs
	- line 287: # TODO: this should only be temporary and removed once v2 migration is done
	- line 298: # TODO: maybe create a read/write klio pub/sub transform to do
	- line 311: # TODO: this should only be temporary and removed once v2 migration is done
	- line 493: # TODO: should prob do some pre-emptive checking
	- line 756: # TODO: maybe expose a way for users to add messages to the pubsub message


lib/src/klio/transforms/_helpers.py (5 lines):
	- line 42: # TODO mabe use klio core config's defs but make them strings
	- line 48: # TODO: maybe use common.MessageState which then should be mapped to
	- line 114: # TODO: fixme: not every child class will inherit from
	- line 185: # TODO: figure out how to support multiple inputs
	- line 235: # TODO: figure out how to support multiple outputs


lib/src/klio/message/pubsub_message_manager.py (4 lines):
	- line 184: # TODO: this method also has `retry` and `timeout` kwargs which
	- line 205: # TODO: either use klio.message.serializer.to_klio_message, or
	- line 242: # TODO: this method also has `retry`, `timeout` and metadata
	- line 286: # TODO: either use klio.message.serializer.to_klio_message, or


lib/src/klio/transforms/io.py (4 lines):
	- line 92: # TODO: merge with helpers.KlioMessageCounter since it's the same logic
	- line 205: # TODO: this is where we should add (relevant) KlioMessage.metadata;
	- line 482: # TODO: this should be a validator in klio_core.config
	- line 598: # TODO: this should be a validator in klio_core.config


exec/src/klio_exec/cli.py (4 lines):
	- line 36: # TODO remove 'INFO:root:' bit from cli status logs.
	- line 37: # TODO make 'ERROR' logs red colored?
	- line 60: # TODO: remove when after internal calls are removed
	- line 106: # TODO: make this a click option once draining is supported @lynn


lib/src/klio/transforms/decorators.py (3 lines):
	- line 86: # TODO: This may be nice to make generic and move into the public helpers
	- line 214: # TODO: update me to `var.KlioRunner.DIRECT_GKE_RUNNER` once
	- line 803: # TODO: Update docstrings w/ new kwargs & examples


cli/src/klio_cli/commands/job/gke.py (3 lines):
	- line 63: # TODO: This grabs configs from '~/.kube/config'. @shireenk
	- line 219: # TODO: If more than one image deployed,
	- line 307: # TODO: add environment labels if/when we support dev/test/prod envs


core/src/klio_core/config/_io.py (3 lines):
	- line 339: # TODO: Add validation
	- line 374: # TODO: integrate into @dsimon's converter logic once his PR#154 is merged
	- line 403: # TODO: use @dsimon's converter logic once his PR#154 is merged in


cli/src/klio_cli/commands/message/publish.py (3 lines):
	- line 53: # [batch dev] TODO: rename entity_id variable in this module
	- line 88: # TODO: should rename argument to something more abstract (@lynn)
	- line 117: # [batch dev] TODO: if we use KlioConfig, we don't have to find the


integration/audio-spectrograms/transforms.py (2 lines):
	- line 35: # TODO: it'd prob be helpful to provide utilities for making use of
	- line 94: # TODO: this could be useful enough to make a generic "group by klio element"


core/src/klio_core/dataflow.py (2 lines):
	- line 63: # TODO: no batch requesting from Google's side, but should add
	- line 169: # TODO: support multiple input topics; will need to


audio/src/klio_audio/transforms/io.py (2 lines):
	- line 27: # TODO: handle multiple data inputs
	- line 114: # TODO: handle multiple data outputs


lib/src/klio/metrics/native.py (2 lines):
	- line 71: # TODO: pull out into a general module since this is copied from logger.py
	- line 251: # TODO: how is timer unit(s) handled?


core/src/klio_core/config/core.py (2 lines):
	- line 359: # TODO: Do we still want this to be the default
	- line 364: # TODO: add validation - if job is instreaming mode and no setup.py,


core/setup.py (2 lines):
	- line 156: "google-api-core>=1.21.0",  # TODO: try and remove
	- line 158: "google-cloud-pubsub",  # TODO: try and remove


lib/src/klio/message/serializer.py (2 lines):
	- line 83: # TODO: when making a generic de/ser func, be sure to assert
	- line 161: # [batch dev] TODO: figure out how/where to clear out this payload


lib/src/klio/metrics/shumway.py (1 line):
	- line 60: # TODO: pull out into a general module since this is copied from logger.py


exec/src/klio_exec/commands/stop.py (1 line):
	- line 23: # TODO: this is nearly identical to klio_cli/commands/stop_job.py. This is


cli/src/klio_cli/commands/job/run.py (1 line):
	- line 53: # TODO: container.logs(stream=True) redirects stderr to stdout.


cli/src/klio_cli/utils/config_utils.py (1 line):
	- line 24: # TODO: integrate this into KlioConfig as a converter


lib/setup.py (1 line):
	- line 171: # TODO: update version dep for klio-audio to PACKAGE_VERSION


core/src/klio_core/variables.py (1 line):
	- line 22: # TODO: Figure out a way to get this dynamically (and maybe fall back to


core/src/klio_core/config/_preprocessing.py (1 line):
	- line 85: # TODO: right now "name" isn't supported in IOConfig (conflicts


cli/src/klio_cli/commands/job/verify.py (1 line):
	- line 252: # TODO: This needs to be overhauled for v2.  Don't assume GCS, pubsub.


exec/src/klio_exec/commands/utils/plugin_utils.py (1 line):
	- line 33: # TODO: in the future, add functionality to toggle & configure audit


cli/src/klio_cli/commands/base.py (1 line):
	- line 71: # TODO: container.logs(stream=True) redirects stderr to stdout.


cli/src/klio_cli/utils/cli_utils.py (1 line):
	- line 48: # TODO: Move this to KlioConfig validation


cli/setup.py (1 line):
	- line 185: # TODO: update version dep for klio-devtools to PACKAGE_VERSION


lib/src/klio/transforms/core.py (1 line):
	- line 89: # TODO: set runner in OS environment (via klio-exec), since


exec/src/klio_exec/commands/audit.py (1 line):
	- line 76: # TODO: Currently, we're running all of the audit steps in