Code Duplication    Length = 35-35 lines in 2 locations

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

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