Skip to content

rs_workflows/on_demand/sentinel3/s3_l1_olci.md

<< Back to index

sentinel 3 OLCI Level-1 processing.

process_s3l1_olci(session, flow_params) async

Sentinel-3 OLCI L1 processing. The input_products should have been processed before by L0.

Source code in docs/rs-client-libraries/rs_workflows/on_demand/sentinel3/s3_l1_olci.py 
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
@flow(name="process-s3-l1-olci")
async def process_s3l1_olci(session: str, flow_params: Level1FlowParams):
    """
    Sentinel-3 OLCI L1 processing.
    The input_products should have been processed before by L0.
    """

    input_products = [
        FlowInputProduct(
            name="S3OLCIL0_1",
            item_id=session,
            collection_name=flow_params.session_collection,
        ),
        FlowInputProduct(
            name="S3OLCIL0_2",
            item_id=session,
            collection_name=flow_params.session_collection,
        ),
        FlowInputProduct(
            name="S3OLCIL0_3",
            item_id=session,
            collection_name=flow_params.session_collection,
        ),
        FlowInputProduct(
            name="S3NAVL0_1",
            item_id=session,
            collection_name=flow_params.session_collection,
        ),
    ]
    mission = "3"

    flow_parameters = await flow_params.resolve(mission)
    satellite_value = f"sentinel-{mission}{session[2].lower()}"

    # temporary
    start_datetime = datetime.now()
    end_datetime = datetime.now()
    #

    # Call DPR flow
    await call_dpr_flow(
        FlowEnvArgs(owner_id=flow_parameters.owner_identifier),
        input_products=input_products,
        external_variables={
            "start_datetime": start_datetime,
            "end_datetime": end_datetime,
            "satellite": satellite_value,
        },
        dask_cluster_label=flow_parameters.dask_cluster_label,
        processor_name=flow_parameters.processor_name,
        processor_version=flow_parameters.processor_version,
        pipeline=flow_parameters.pipeline,
        unit=flow_parameters.unit,
        priority=flow_parameters.priority,
        processing_mode=flow_parameters.processing_mode,
        workflow=flow_parameters.workflow,
        generated_product_to_collection_identifier=flow_parameters.generated_product_to_collection_identifier or [],
        auxiliary_product_to_collection_identifier=flow_parameters.auxiliary_product_to_collection_identifier or [],
        logging_level=flow_parameters.logging_level,
    )

process_s3l1_olci_task(*args, **kwargs) async

See: dpr_processing

Source code in docs/rs-client-libraries/rs_workflows/on_demand/sentinel3/s3_l1_olci.py 
88
89
90
91
@task(name="process-s3-l1-olci")
async def process_s3l1_olci_task(*args, **kwargs) -> None:
    """See: dpr_processing"""
    return await process_s3l1_olci.fn(*args, **kwargs)