Code Duplication    Length = 35-35 lines in 2 locations

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

@@ 231-265 (lines=35) @@
228
            warning=False,
229
        )
230
231
        if (
232
            sum_output.output_capacity_mw.sum() == 0
233
            and sum_input.input_capacity_mw.sum() == 0
234
        ):
235
            print(
236
                f"No capacity for carrier '{carrier}' needed to be "
237
                f"distributed. Everything is fine"
238
            )
239
240
        elif (
241
            sum_input.input_capacity_mw.sum() > 0
242
            and sum_output.output_capacity_mw.sum() == 0
243
        ):
244
            print(
245
                f"Error: Capacity for carrier '{carrier}' was not distributed"
246
                f" at all!"
247
            )
248
249
        elif (
250
            sum_output.output_capacity_mw.sum() > 0
251
            and sum_input.input_capacity_mw.sum() == 0
252
        ):
253
            print(
254
                f"Error: Eventhough no input capacity was provided for carrier"
255
                f" '{carrier}' a capacity got distributed!"
256
            )
257
258
        else:
259
            sum_input["error"] = (
260
                (sum_output.output_capacity_mw - sum_input.input_capacity_mw)
261
                / sum_input.input_capacity_mw
262
            ) * 100
263
            g = sum_input["error"].values[0]
264
265
            print(f"{carrier}: " + str(round(g, 2)) + " %")
266
267
    # Section to check loads
268
@@ 158-192 (lines=35) @@
155
            warning=False,
156
        )
157
158
        if (
159
            sum_output.output_capacity_mw.sum() == 0
160
            and sum_input.input_capacity_mw.sum() == 0
161
        ):
162
            logger.info(
163
                f"No capacity for carrier '{carrier}' needed to be"
164
                f" distributed. Everything is fine"
165
            )
166
167
        elif (
168
            sum_input.input_capacity_mw.sum() > 0
169
            and sum_output.output_capacity_mw.sum() == 0
170
        ):
171
            logger.info(
172
                f"Error: Capacity for carrier '{carrier}' was not distributed "
173
                f"at all!"
174
            )
175
176
        elif (
177
            sum_output.output_capacity_mw.sum() > 0
178
            and sum_input.input_capacity_mw.sum() == 0
179
        ):
180
            logger.info(
181
                f"Error: Eventhough no input capacity was provided for carrier"
182
                f"'{carrier}' a capacity got distributed!"
183
            )
184
185
        else:
186
            sum_input["error"] = (
187
                (sum_output.output_capacity_mw - sum_input.input_capacity_mw)
188
                / sum_input.input_capacity_mw
189
            ) * 100
190
            g = sum_input["error"].values[0]
191
192
            logger.info(f"{carrier}: " + str(round(g, 2)) + " %")
193
194
    # Section to check storage units
195