Skip to content

rs_dpr_service/processors/eopf_processors.md

<< Back to index

Implementation of EOPF processors based on GenericProcessor. Processors: S1L0, S3L0, S1ARD.

MockupProcessor

Bases: GenericProcessor

Mockup Processor implementation

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
class MockupProcessor(GenericProcessor):
    """Mockup Processor implementation"""

    def __init__(self, db_process_manager: PostgreSQLManager, cluster_info: ClusterInfo):
        """
        Initialize S1L0Processor
        """
        super().__init__(
            db_process_manager=db_process_manager,
            cluster_info=cluster_info,
            local_mode_address="DASK_GATEWAY_EOPF_MOCKUP_ADDRESS",
            tasktable_module="",
            tasktable_class="",
        )
        self.use_mockup = True

    async def get_tasktable(self):
        """Return the EOPF tasktable"""
        return _load_tasktable("tasktable.json")

__init__(db_process_manager, cluster_info)

Initialize S1L0Processor

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
39
40
41
42
43
44
45
46
47
48
49
50
def __init__(self, db_process_manager: PostgreSQLManager, cluster_info: ClusterInfo):
    """
    Initialize S1L0Processor
    """
    super().__init__(
        db_process_manager=db_process_manager,
        cluster_info=cluster_info,
        local_mode_address="DASK_GATEWAY_EOPF_MOCKUP_ADDRESS",
        tasktable_module="",
        tasktable_class="",
    )
    self.use_mockup = True

get_tasktable() async

Return the EOPF tasktable

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
52
53
54
async def get_tasktable(self):
    """Return the EOPF tasktable"""
    return _load_tasktable("tasktable.json")

S1ARDProcessor

Bases: GenericProcessor

S1ARD Processor implementation

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
class S1ARDProcessor(GenericProcessor):
    """S1ARD Processor implementation"""

    def __init__(self, db_process_manager: PostgreSQLManager, cluster_info: ClusterInfo):
        """
        Initialize S1ARDProcessor
        """
        super().__init__(
            db_process_manager=db_process_manager,
            cluster_info=cluster_info,
            local_mode_address="DASK_GATEWAY_S1ARD_ADDRESS",
            tasktable_module="s1_l12_rp.computing.ard_processing_units",
            # NOTE: not implemented for now... and maybe we should be able to return the
            # tasktable for each different processing: Calibration, ReferenceDEM, ReferenceGeometry, ...
            tasktable_class="Calibration",
        )

    async def get_tasktable(self):
        """Return the EOPF tasktable"""
        return _load_tasktable("TaskTable_S1_ARD_generated_by_rs_python_v1.json")

__init__(db_process_manager, cluster_info)

Initialize S1ARDProcessor

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
100
101
102
103
104
105
106
107
108
109
110
111
112
def __init__(self, db_process_manager: PostgreSQLManager, cluster_info: ClusterInfo):
    """
    Initialize S1ARDProcessor
    """
    super().__init__(
        db_process_manager=db_process_manager,
        cluster_info=cluster_info,
        local_mode_address="DASK_GATEWAY_S1ARD_ADDRESS",
        tasktable_module="s1_l12_rp.computing.ard_processing_units",
        # NOTE: not implemented for now... and maybe we should be able to return the
        # tasktable for each different processing: Calibration, ReferenceDEM, ReferenceGeometry, ...
        tasktable_class="Calibration",
    )

get_tasktable() async

Return the EOPF tasktable

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
114
115
116
async def get_tasktable(self):
    """Return the EOPF tasktable"""
    return _load_tasktable("TaskTable_S1_ARD_generated_by_rs_python_v1.json")

S1L0Processor

Bases: GenericProcessor

S1L0 Processor implementation

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
class S1L0Processor(GenericProcessor):
    """S1L0 Processor implementation"""

    def __init__(self, db_process_manager: PostgreSQLManager, cluster_info: ClusterInfo):
        """
        Initialize S1L0Processor
        """
        super().__init__(
            db_process_manager=db_process_manager,
            cluster_info=cluster_info,
            local_mode_address="DASK_GATEWAY_L0_ADDRESS",
            tasktable_module="l0.s1.s1_l0_processor",
            tasktable_class="S1L0Processor",
        )

    async def get_tasktable(self):
        """Return the EOPF tasktable"""
        return _load_tasktable("TaskTable_S1_L0_generated_by_rs_python_v1.json")

__init__(db_process_manager, cluster_info)

Initialize S1L0Processor

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
60
61
62
63
64
65
66
67
68
69
70
def __init__(self, db_process_manager: PostgreSQLManager, cluster_info: ClusterInfo):
    """
    Initialize S1L0Processor
    """
    super().__init__(
        db_process_manager=db_process_manager,
        cluster_info=cluster_info,
        local_mode_address="DASK_GATEWAY_L0_ADDRESS",
        tasktable_module="l0.s1.s1_l0_processor",
        tasktable_class="S1L0Processor",
    )

get_tasktable() async

Return the EOPF tasktable

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
72
73
74
async def get_tasktable(self):
    """Return the EOPF tasktable"""
    return _load_tasktable("TaskTable_S1_L0_generated_by_rs_python_v1.json")

S3L0Processor

Bases: GenericProcessor

S3L0 Processor implementation

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
class S3L0Processor(GenericProcessor):
    """S3L0 Processor implementation"""

    def __init__(self, db_process_manager: PostgreSQLManager, cluster_info: ClusterInfo):
        """
        Initialize S3L0Processor
        """
        super().__init__(
            db_process_manager=db_process_manager,
            cluster_info=cluster_info,
            local_mode_address="DASK_GATEWAY_L0_ADDRESS",
            tasktable_module="l0.s3.s3_l0_processor",
            tasktable_class="S3L0Processor",
        )

    async def get_tasktable(self):
        """Return the EOPF tasktable"""
        return _load_tasktable("TaskTable_S3_L0_generated_by_rs_python_v1.json")

__init__(db_process_manager, cluster_info)

Initialize S3L0Processor

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
80
81
82
83
84
85
86
87
88
89
90
def __init__(self, db_process_manager: PostgreSQLManager, cluster_info: ClusterInfo):
    """
    Initialize S3L0Processor
    """
    super().__init__(
        db_process_manager=db_process_manager,
        cluster_info=cluster_info,
        local_mode_address="DASK_GATEWAY_L0_ADDRESS",
        tasktable_module="l0.s3.s3_l0_processor",
        tasktable_class="S3L0Processor",
    )

get_tasktable() async

Return the EOPF tasktable

Source code in docs/rs-dpr-service/rs_dpr_service/processors/eopf_processors.py 
92
93
94
async def get_tasktable(self):
    """Return the EOPF tasktable"""
    return _load_tasktable("TaskTable_S3_L0_generated_by_rs_python_v1.json")