metaflow/plugins/argo/argo_workflows.py (29 lines): - line 266: # TODO: Only look for workflows for the specified flow - line 355: # TODO: Add configuration through an environment variable or Metaflow config in the future if required. - line 366: # TODO: Add configuration through an environment variable or Metaflow config in the future if required. - line 612: # TODO: Add a check to guard against names starting with numerals(?) - line 685: # TODO: Add a time filters to guard against cached events - line 818: # TODO: Allow Argo to optionally archive all workflow execution logs - line 825: # TODO: Service account names are currently set in the templates. We - line 829: # TODO: Support ImagePullSecrets for Argo & Kubernetes - line 835: # TODO: Support Prometheus metrics for Argo - line 837: # TODO: Support PodGC and DisruptionBudgets - line 851: # TODO: Set dynamic labels using labels_from. Ideally, we would - line 868: # TODO: Better handle IncludeFile in Argo Workflows UI. - line 1377: # TODO : Pass down these parameters to the jobset stuff. - line 1438: # TODO: Support R someday. Quite a few people will be happy. - line 2198: # TODO: Unify the logic with kubernetes.py - line 2413: # FIXME: this can be brittle. - line 2425: # TODO: Also capture the first failed task id - line 2527: # "dedup_key": self.flow.name, # TODO: Do we need deduplication? - line 2849: # TODO: we do not really need MFLOG logging for the daemon at the moment, but might be good for the future. - line 2862: # TODO: Can the init be trimmed down? - line 2877: # FIXME: this can be brittle. - line 2937: # TODO: Make the image configurable - line 3124: # TODO (savin): Handle bypassing docker image rate limit errors. - line 3127: # TODO (savin): Allow for multiple replicas for HA. - line 3129: # TODO: Support revision history limit to manage old deployments - line 3263: # TODO: Introduce "end_of_day", "end_of_hour" .. - line 3281: # TODO: Alternatively fetch this from @trigger config options - line 3358: # TODO: Autogenerate them, maybe? - line 3953: # TODO: Make number of deployment replicas configurable. metaflow/plugins/pypi/conda_environment.py (9 lines): - line 39: # TODO: Make life simple by passing echo to the constructor and getting rid of - line 72: # TODO: Wire up logging - line 82: # TODO: Introduce verbose logging - line 161: # TODO: Depending on the len_hint, the package might be downloaded from - line 286: # TODO: Support dependencies for `--metadata`. - line 287: # TODO: Introduce support for `--telemetry` as a follow up. - line 442: # TODO: Make this an instance variable once local_root is part of the object - line 515: # TODO: Remove dependency on requests - line 519: # TODO: Stream it in chunks? metaflow/plugins/argo/argo_workflows_cli.py (8 lines): - line 24: # TODO: Move production_token to utils - line 155: default=True, # TODO: Default to a value from config - line 263: # TODO: Consider dispelling with this check since it's been 2 years since the - line 302: # TODO: Support echo-ing Argo Events Sensor template - line 334: # TODO: Print events emitted by execution of this flow - line 476: # TODO: Make this check less specific to Amazon S3 as we introduce - line 558: # TODO: Unify this method with the one in step_functions_cli.py - line 874: # TODO: Unify this with the existing resolve_token implementation. metaflow/plugins/kubernetes/kubernetes_job.py (7 lines): - line 98: * 60 # Remove job after a week. TODO: Make this configurable - line 109: # TODO (savin): Enable affinities for GPU scheduling. - line 217: # TODO (savin): Support image_pull_secrets - line 219: # TODO (savin): Support preemption policies - line 312: # TODO: Make job submission back-pressure aware. Currently - line 510: # TODO: stream opens a web-socket connection. It may - line 605: # TODO (savin): parse Pod conditions metaflow/plugins/kubernetes/kubernetes_decorator.py (6 lines): - line 364: # TODO: Fix https://github.com/Netflix/metaflow/issues/467 - line 424: # TODO: add validation to annotations as well? - line 538: # TODO (savin): Introduce equivalent support for Microsoft Azure and - line 540: # TODO: Introduce a way to detect Cloud Provider, so unnecessary requests - line 614: # TODO: There is no guarantee that task_pre_step executes before - line 639: # TODO: Unify this method with the multi-node setup in @batch metaflow/client/core.py (6 lines): - line 990: # TODO: Pass proper environment to properly extract artifacts - line 995: # TODO: We can store more information in the metadata, particularly - line 1036: # TODO: Pass proper environment to properly extract artifacts - line 1047: # TODO add - line 1659: # FIXME: Technically we are looking at the latest *recorded* attempt - line 2148: # TODO: A more optimized way of figuring out if a run has remote steps (and thus a codepackage) available. metaflow/plugins/cards/card_modules/card.py (5 lines): - line 67: # FIXME document runtime_data - line 100: # FIXME document - line 104: # FIXME document - line 108: # FIXME document - line 135: #FIXME document metaflow/plugins/kubernetes/kubernetes_jobsets.py (5 lines): - line 17: # TODO [DUPLICATE CODE]: Refactor this method to a separate file so that - line 590: * 60 # Remove job after a week. TODO: Make this configurable - line 605: # TODO (savin): Enable affinities for GPU scheduling. - line 721: # TODO (savin): Support image_pull_secrets - line 723: # TODO (savin): Support preemption policies metaflow/plugins/pypi/micromamba.py (4 lines): - line 73: # TODO: Make this optional at some point. - line 107: # TODO: Make the version configurable - line 130: # TODO: Ensure a human readable message is returned when the environment - line 233: # TODO: Check bin/python is available as a heuristic for well formed env metaflow/plugins/argo/argo_events.py (4 lines): - line 40: # TODO: Introduce support for NATS - line 104: # TODO: Test with bearer tokens - line 108: # TODO: do we need to worry about certs? - line 141: # TODO: Retry retryable HTTP error codes metaflow/plugins/pypi/conda_decorator.py (4 lines): - line 120: # TODO: Hardcoded for now to support the fast bakery environment. - line 141: # TODO: This code snippet can be done away with by altering the constructor of - line 333: # TODO: Migrate conda_base keyword to conda for simplicity. - line 381: # TODO: Hardcoded for now to support the fast bakery environment. metaflow/cli.py (3 lines): - line 538: # TODO (savin): Enable lazy instantiation of package - line 548: # TODO set linter settings - line 606: # TODO: This serves as a short term workaround for RuntimeWarning(s) thrown metaflow/plugins/cards/component_serializer.py (3 lines): - line 776: # FIXME: document - line 800: # FIXME: document - line 805: # FIXME: document metaflow/cmd/configure_cmd.py (3 lines): - line 84: # TODO: Should we persist empty env_dict or notify user differently? - line 224: # TODO: Add the URL for contact us page in the error? - line 276: # TODO rename this Blob Endpoint! metaflow/plugins/kubernetes/kubernetes.py (3 lines): - line 138: # TODO: Capture hard exit logs in Kubernetes. - line 745: # TODO : If we notice Kubernetes failing to upload logs to S3, - line 749: # TODO : For hard crashes, we can fetch logs from the pod. metaflow/plugins/pypi/pypi_decorator.py (3 lines): - line 84: # TODO: Hardcoded for now to support the fast bakery environment. - line 101: # TODO: This code snippet can be done away with by altering the constructor of - line 154: # TODO: Hardcoded for now to support the fast bakery environment. metaflow/runtime.py (2 lines): - line 73: # TODO option: output dot graph periodically about execution - line 1561: # TODO: Make one with dict_to_cli_options; see cli_args.py for more detail metaflow/plugins/events_decorator.py (2 lines): - line 10: # TODO: Support dynamic parameter mapping through a context object that exposes - line 207: # TODO: Handle scenario for local testing using --trigger. metaflow/decorators.py (2 lines): - line 165: # TODO: Do we really want to allow spaces in the names of attributes?!? - line 297: TODO (savin): Initialize the decorators with flow, graph, metaflow/plugins/pypi/__init__.py (2 lines): - line 7: # TODO: This can be lifted all the way into metaflow config - line 20: # TODO: Throw a more evocative error message metaflow/plugins/aws/aws_utils.py (2 lines): - line 33: # TODO: Remove dependency on requests - line 165: # TODO: Throw a better exception since the user has no metaflow/cli_args.py (2 lines): - line 4: # TODO: We have two CLIArgs: - line 11: # TODO: dict_to_cli_options uses shlex which causes some issues with this as metaflow/plugins/airflow/airflow.py (2 lines): - line 46: # TODO: Move chevron to _vendor - line 773: # TODO: Enable emails metaflow/runner/subprocess_manager.py (2 lines): - line 16: # TODO: there's a race condition that new descendants might - line 37: # TODO: there's a race condition that new descendants might metaflow/plugins/cards/card_client.py (1 line): - line 313: environment=None, # TODO: Add environment here metaflow/plugins/aws/batch/batch_client.py (1 line): - line 764: # TODO: Check statusmessage to find if the job crashed instead of failing metaflow/plugins/aws/step_functions/schedule_decorator.py (1 line): - line 4: # TODO (savin): Lift this decorator up since it's also used by Argo now metaflow/plugins/kubernetes/kubernetes_client.py (1 line): - line 50: # TODO (savin): metaflow/plugins/cards/card_modules/chevron/renderer.py (1 line): - line 341: # TODO: This feels like it still has edge cases, no? metaflow/parameters.py (1 line): - line 393: # TODO: check that the type is one of the supported types metaflow/plugins/env_escape/client_modules.py (1 line): - line 57: # TODO: Grab doc back from the remote side like in _make_method metaflow/plugins/aws/secrets_manager/aws_secrets_manager_secrets_provider.py (1 line): - line 99: # TODO: Find a way to show a concise error in logs metaflow/client/filecache.py (1 line): - line 378: environment=None, # TODO: Add environment here metaflow/plugins/aws/batch/batch_decorator.py (1 line): - line 280: # TODO: Remove dependency on requests metaflow/user_configs/config_options.py (1 line): - line 368: # TODO: Support YAML metaflow/plugins/kubernetes/kube_utils.py (1 line): - line 59: # TODO: Add support for BestEffort once there is a use case for it. metaflow/datastore/task_datastore.py (1 line): - line 511: TODO: Should we make this take multiple names like the other calls? metaflow/datastore/inputs.py (1 line): - line 9: # TODO sort by foreach index metaflow/plugins/storage_executor.py (1 line): - line 108: # TODO keyboard interrupt crazy tracebacks in process pool metaflow/plugins/azure/azure_utils.py (1 line): - line 24: # TODO but what if folks want to debug on occasion? metaflow/plugins/airflow/airflow_cli.py (1 line): - line 192: # TODO (savin): Identify the default namespace? metaflow/sidecar/sidecar_subprocess.py (1 line): - line 82: # TODO: Python 2 shipped by Anaconda allows for metaflow/plugins/uv/bootstrap.py (1 line): - line 11: # TODO: support version/platform/architecture selection. metaflow/plugins/argo/argo_workflows_decorator.py (1 line): - line 146: # TODO: Check length limits for fields in Argo Events metaflow/plugins/parallel_decorator.py (1 line): - line 203: # TODO: Logs for worker processes are assigned to control process as of today, which metaflow/plugins/gcp/gs_utils.py (1 line): - line 64: # TODO we may catch and wrap more GCP errors here, as needed. metaflow/runner/click_api.py (1 line): - line 185: # TODO: possibly check for fake groups with cmd_obj.name in ["cli", "main"] metaflow/plugins/cards/card_datastore.py (1 line): - line 234: # TEMPORARY_WORKAROUND: FIXME (LATER) : Fix the duplication of below block in a few months. metaflow/plugins/aws/step_functions/production_token.py (1 line): - line 41: # TODO make this a MF config variable metaflow/plugins/pypi/pip.py (1 line): - line 47: # TODO: metaflow/plugins/datatools/s3/s3op.py (1 line): - line 405: # TODO specific error message for out of disk space metaflow/cmd/tutorials_cmd.py (1 line): - line 133: # TODO: Is the following redundant? metaflow/cmd/develop/stub_generator.py (1 line): - line 948: # TODO: This only handles the `Parameters` section for now; we are metaflow/flowspec.py (1 line): - line 315: # TODO: This means that users can't override configs directly. Not sure if this metaflow/plugins/env_escape/stub.py (1 line): - line 109: # def __iter__(self): # FIXME: Keep debugger QUIET!! metaflow/plugins/pypi/bootstrap.py (1 line): - line 199: # # TODO: consider RAM disk metaflow/plugins/metadata_providers/service.py (1 line): - line 461: # TODO _request() needs a more deliberate refactor at some point, it looks quite overgrown. metaflow/plugins/aws/step_functions/set_batch_environment.py (1 line): - line 32: # TODO: Maybe use click someday instead of conditional. metaflow/plugins/aws/step_functions/step_functions_cli.py (1 line): - line 771: # TODO: Unify this with the existing resolve_token implementation. metaflow/extension_support/__init__.py (1 line): - line 249: # TODO: This does not properly work for multiple packages that overwrite