Code Duplication    Length = 35-35 lines in 2 locations

src/egon/data/datasets/sanity_checks.py 2 locations

@@ 189-223 (lines=35) @@
186
            warning=False,
187
        )
188
189
        if (
190
            sum_output.output_capacity_mw.sum() == 0
191
            and sum_input.input_capacity_mw.sum() == 0
192
        ):
193
            logger.info(
194
                f"No capacity for carrier '{carrier}' needed to be "
195
                f"distributed. Everything is fine"
196
            )
197
198
        elif (
199
            sum_input.input_capacity_mw.sum() > 0
200
            and sum_output.output_capacity_mw.sum() == 0
201
        ):
202
            logger.info(
203
                f"Error: Capacity for carrier '{carrier}' was not distributed"
204
                f" at all!"
205
            )
206
207
        elif (
208
            sum_output.output_capacity_mw.sum() > 0
209
            and sum_input.input_capacity_mw.sum() == 0
210
        ):
211
            logger.info(
212
                f"Error: Eventhough no input capacity was provided for carrier"
213
                f" '{carrier}' a capacity got distributed!"
214
            )
215
216
        else:
217
            sum_input["error"] = (
218
                (sum_output.output_capacity_mw - sum_input.input_capacity_mw)
219
                / sum_input.input_capacity_mw
220
            ) * 100
221
            g = sum_input["error"].values[0]
222
223
            logger.info(f"{carrier}: " + str(round(g, 2)) + " %")
224
225
    # Section to check loads
226
@@ 116-150 (lines=35) @@
113
            warning=False,
114
        )
115
116
        if (
117
            sum_output.output_capacity_mw.sum() == 0
118
            and sum_input.input_capacity_mw.sum() == 0
119
        ):
120
            logger.info(
121
                f"No capacity for carrier '{carrier}' needed to be"
122
                f" distributed. Everything is fine"
123
            )
124
125
        elif (
126
            sum_input.input_capacity_mw.sum() > 0
127
            and sum_output.output_capacity_mw.sum() == 0
128
        ):
129
            logger.info(
130
                f"Error: Capacity for carrier '{carrier}' was not distributed "
131
                f"at all!"
132
            )
133
134
        elif (
135
            sum_output.output_capacity_mw.sum() > 0
136
            and sum_input.input_capacity_mw.sum() == 0
137
        ):
138
            logger.info(
139
                f"Error: Eventhough no input capacity was provided for carrier"
140
                f"'{carrier}' a capacity got distributed!"
141
            )
142
143
        else:
144
            sum_input["error"] = (
145
                (sum_output.output_capacity_mw - sum_input.input_capacity_mw)
146
                / sum_input.input_capacity_mw
147
            ) * 100
148
            g = sum_input["error"].values[0]
149
150
            logger.info(f"{carrier}: " + str(round(g, 2)) + " %")
151
152
    # Section to check storage units
153