ogdc_runner.workflow.viz_workflow module

ogdc_runner.workflow.viz_workflow.batch_process(num_features) → None

Processes data in batches.

Return type:

None

ogdc_runner.workflow.viz_workflow.make_and_submit_viz_workflow(recipe_config: RecipeConfig, wait: bool) → str

Create and submit an Argo workflow for parallel processing of geospatial data.

This workflow follows the pattern from the ‘ogdc-recipe-ice-basins-pdg’ Argo workflow, using Hera’s Python API instead of YAML.

Parameters:

• recipe_config (RecipeConfig) – The recipe configuration

• wait (bool) – Whether to wait for the workflow to complete

• input_url – URL to the input data file

Return type:

str

Returns:

The name of the submitted workflow

ogdc_runner.workflow.viz_workflow.tiling_process() → None

Creates tiles from a geospatial data chunk.

Return type:

None