Code Duplication    Length = 35-35 lines in 2 locations

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

@@ 259-293 (lines=35) @@
256
            warning=False,
257
        )
258
259
        if (
260
            sum_output.output_capacity_mw.sum() == 0
261
            and sum_input.input_capacity_mw.sum() == 0
262
        ):
263
            print(
264
                f"No capacity for carrier '{carrier}' needed to be "
265
                f"distributed. Everything is fine"
266
            )
267
268
        elif (
269
            sum_input.input_capacity_mw.sum() > 0
270
            and sum_output.output_capacity_mw.sum() == 0
271
        ):
272
            print(
273
                f"Error: Capacity for carrier '{carrier}' was not distributed"
274
                f" at all!"
275
            )
276
277
        elif (
278
            sum_output.output_capacity_mw.sum() > 0
279
            and sum_input.input_capacity_mw.sum() == 0
280
        ):
281
            print(
282
                f"Error: Eventhough no input capacity was provided for carrier"
283
                f" '{carrier}' a capacity got distributed!"
284
            )
285
286
        else:
287
            sum_input["error"] = (
288
                (sum_output.output_capacity_mw - sum_input.input_capacity_mw)
289
                / sum_input.input_capacity_mw
290
            ) * 100
291
            g = sum_input["error"].values[0]
292
293
            print(f"{carrier}: " + str(round(g, 2)) + " %")
294
295
    # Section to check loads
296
@@ 186-220 (lines=35) @@
183
            warning=False,
184
        )
185
186
        if (
187
            sum_output.output_capacity_mw.sum() == 0
188
            and sum_input.input_capacity_mw.sum() == 0
189
        ):
190
            logger.info(
191
                f"No capacity for carrier '{carrier}' needed to be"
192
                f" distributed. Everything is fine"
193
            )
194
195
        elif (
196
            sum_input.input_capacity_mw.sum() > 0
197
            and sum_output.output_capacity_mw.sum() == 0
198
        ):
199
            logger.info(
200
                f"Error: Capacity for carrier '{carrier}' was not distributed "
201
                f"at all!"
202
            )
203
204
        elif (
205
            sum_output.output_capacity_mw.sum() > 0
206
            and sum_input.input_capacity_mw.sum() == 0
207
        ):
208
            logger.info(
209
                f"Error: Eventhough no input capacity was provided for carrier"
210
                f"'{carrier}' a capacity got distributed!"
211
            )
212
213
        else:
214
            sum_input["error"] = (
215
                (sum_output.output_capacity_mw - sum_input.input_capacity_mw)
216
                / sum_input.input_capacity_mw
217
            ) * 100
218
            g = sum_input["error"].values[0]
219
220
            logger.info(f"{carrier}: " + str(round(g, 2)) + " %")
221
222
    # Section to check storage units
223