rs_workflows/on_demand/sentinel1/s1_ard.md

<< Back to index

sentinel 1 ARD processing.

process_s1ard(slcs, reference_date, edh_api_key, env_args, pipeline=None, verbose=False) async

Sentinel-1 ARD processing (nominal on-demand flow).

Args:
    slcs: STAC item identifiers of S1 SLC input products, already converted to zarr.
    reference_date: Date of the master (reference) SLC
    edh_api_key: Destination Earth / EarthDataHub standard API key used to access Copernicus DEM
    env_args: Flow environment arguments
    pipeline: Pipeline to run (default: the pipeline of the `s1ard-default-setting` Prefect variable)

Source code in docs/rs-client-libraries/rs_workflows/on_demand/sentinel1/s1_ard.py

@flow(name="process-s1-ard")
async def process_s1ard(
    slcs: list[str],
    reference_date: date,
    edh_api_key: str,
    env_args: FlowEnvArgs,
    pipeline: S1ArdPipeline | None = None,
    verbose: bool = False,
):
    """
    Sentinel-1 ARD processing (nominal on-demand flow).

        Args:
            slcs: STAC item identifiers of S1 SLC input products, already converted to zarr.
            reference_date: Date of the master (reference) SLC
            edh_api_key: Destination Earth / EarthDataHub standard API key used to access Copernicus DEM
            env_args: Flow environment arguments
            pipeline: Pipeline to run (default: the pipeline of the `s1ard-default-setting` Prefect variable)
    """

    # Specific data used for tests:
    # https://stac.dataspace.copernicus.eu/v1/collections/sentinel-1-slc/items/S1D_IW_SLC__1SDV_20260420T055953_20260420T060020_002426_003FB6_3AE6
    # https://stac.dataspace.copernicus.eu/v1/collections/sentinel-1-slc/items/S1C_IW_SLC__1SDV_20260408T174632_20260408T174659_007128_00E6F6_E998
    # https://stac.dataspace.copernicus.eu/v1/collections/sentinel-1-slc/items/S1C_IW_SLC__1SDV_20260327T174632_20260327T174659_006953_00E115_D167

    # https://earthdatahub.destine.eu/api/stac/v1/collections/copernicus-dem/items/GLO-30

    await _do_process_s1ard(slcs, reference_date, edh_api_key, env_args, pipeline, verbose)

process_s1ard_reference(slc, edh_api_key, env_args, verbose=False) async

Sentinel-1 ARD processing reference pipeline. This flow must be run once to generate the REFERENCE_DB used in on-demand S1 ARD processing flow.

Args:
    slc: STAC item identifier of S1 master SLC input product, already converted to zarr.
    edh_api_key: Destination Earth / EarthDataHub standard API key used to access Copernicus DEM
    env_args: Flow environment arguments

Source code in docs/rs-client-libraries/rs_workflows/on_demand/sentinel1/s1_ard.py

@flow(name="process-s1-ard-reference")
async def process_s1ard_reference(slc: str, edh_api_key: str, env_args: FlowEnvArgs, verbose: bool = False):
    """
    Sentinel-1 ARD processing reference pipeline.
    This flow must be run once to generate the REFERENCE_DB used in on-demand S1 ARD processing flow.

        Args:
            slc: STAC item identifier of S1 master SLC input product, already converted to zarr.
            edh_api_key: Destination Earth / EarthDataHub standard API key used to access Copernicus DEM
            env_args: Flow environment arguments
    """
    await _do_process_s1ard([slc], None, edh_api_key, env_args, DprPipeline.S1ARD_REF.value, verbose)

process_s1l1ard_reference_task(*args, **kwargs) async

See: dpr_processing

Source code in docs/rs-client-libraries/rs_workflows/on_demand/sentinel1/s1_ard.py

@task(name="process sentinel-1 level-1-ard reference pipeline")
async def process_s1l1ard_reference_task(*args, **kwargs) -> None:
    """See: dpr_processing"""
    return await process_s1ard_reference.fn(*args, **kwargs)

process_s1l1ard_task(*args, **kwargs) async

See: dpr_processing

Source code in docs/rs-client-libraries/rs_workflows/on_demand/sentinel1/s1_ard.py

@task(name="process sentinel-1 level-1-ard")
async def process_s1l1ard_task(*args, **kwargs) -> None:
    """See: dpr_processing"""
    return await process_s1ard.fn(*args, **kwargs)