data.datasets.storages.allocate_pumped_hydro_eGon2035() - Code Metrics - Inspection of "Merge pull request #898 from openego/feature/#749-..." - openego/eGon-data - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — dev ( 3dcd28...416f54 )

unknown

created 2022-11-01 12:18 UTC

allocate_pumped_hydro_eGon2035() B

↳ Parent: data.datasets.storages

Complexity

Conditions

Size

Total Lines	178
Code Lines	96

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	96
dl	0
loc	178
rs	7.1309
c	0
b	0
f	0
cc	4
nop	1

How to fix Long Method

"""The central module containing all code dealing with power plant data.
"""
from geoalchemy2 import Geometry
from pathlib import Path
from sqlalchemy import BigInteger, Column, Float, Integer, Sequence, String
from sqlalchemy.dialects.postgresql import JSONB
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
from egon.data.datasets.storages.pumped_hydro import (
    select_mastr_pumped_hydro,
    select_nep_pumped_hydro,
    match_storage_units,
    get_location,
    apply_voltage_level_thresholds,
)
from egon.data.datasets.power_plants import assign_voltage_level
import geopandas as gpd
import pandas as pd

from egon.data import db, config
from egon.data.datasets import Dataset


Base = declarative_base()


class EgonStorages(Base):

    __tablename__ = "egon_storages"
    __table_args__ = {"schema": "supply"}
    id = Column(BigInteger, Sequence("storage_seq"), primary_key=True)
    sources = Column(JSONB)
    source_id = Column(JSONB)
    carrier = Column(String)
    el_capacity = Column(Float)
    bus_id = Column(Integer)
    voltage_level = Column(Integer)
    scenario = Column(String)
    geom = Column(Geometry("POINT", 4326))


class PumpedHydro(Dataset):
    def __init__(self, dependencies):
        super().__init__(
            name="Storages",
            version="0.0.2",
            dependencies=dependencies,
            tasks=(
                create_tables,
                allocate_pumped_hydro_eGon2035,
                allocate_pumped_hydro_eGon100RE,
                allocate_pv_home_batteries,
            ),
        )


def create_tables():
    """Create tables for power plant data
    Returns
    -------
    None.
    """

    cfg = config.datasets()["storages"]
    db.execute_sql(f"CREATE SCHEMA IF NOT EXISTS {cfg['target']['schema']};")
    engine = db.engine()
    db.execute_sql(
        f"""DROP TABLE IF EXISTS
        {cfg['target']['schema']}.{cfg['target']['table']}"""
    )

    db.execute_sql("""DROP SEQUENCE IF EXISTS pp_seq""")
    EgonStorages.__table__.create(bind=engine, checkfirst=True)


def allocate_pumped_hydro_eGon2035(export=True):
    """Allocates pumped_hydro plants for eGon2035 scenario and either exports
    results to data base or returns as a dataframe

    Parameters
    ----------
    export : bool
        Choose if allocated pumped hydro plants should be exported to the data
        base. The default is True.
        If export=False a data frame will be returned

    Returns
    -------
    power_plants : pandas.DataFrame
        List of pumped hydro plants in 'eGon2035' scenario
    """

    carrier = "pumped_hydro"

    cfg = config.datasets()["power_plants"]

    nep = select_nep_pumped_hydro()
    mastr = select_mastr_pumped_hydro()

    # Assign voltage level to MaStR
    mastr["voltage_level"] = assign_voltage_level(
        mastr.rename({"el_capacity": "Nettonennleistung"}, axis=1), cfg
    )

    # Initalize DataFrame for matching power plants
    matched = gpd.GeoDataFrame(
        columns=[
            "carrier",
            "el_capacity",
            "scenario",
            "geometry",
            "MaStRNummer",
            "source",
            "voltage_level",
        ]
    )

    # Match pumped_hydro units from NEP list
    # using PLZ and capacity
    matched, mastr, nep = match_storage_units(
        nep, mastr, matched, buffer_capacity=0.1, consider_carrier=False
    )

    # Match plants from NEP list using plz,
    # neglecting the capacity
    matched, mastr, nep = match_storage_units(
        nep,
        mastr,
        matched,
        consider_location="plz",
        consider_carrier=False,
        consider_capacity=False,
    )

    # Match plants from NEP list using city,
    # neglecting the capacity
    matched, mastr, nep = match_storage_units(
        nep,
        mastr,
        matched,
        consider_location="city",
        consider_carrier=False,
        consider_capacity=False,
    )

    # Match remaining plants from NEP using the federal state
    matched, mastr, nep = match_storage_units(
        nep,
        mastr,
        matched,
        buffer_capacity=0.1,
        consider_location="federal_state",
        consider_carrier=False,
    )

    # Match remaining plants from NEP using the federal state
    matched, mastr, nep = match_storage_units(
        nep,
        mastr,
        matched,
        buffer_capacity=0.7,
        consider_location="federal_state",
        consider_carrier=False,
    )

    print(f"{matched.el_capacity.sum()} MW of {carrier} matched")
    print(f"{nep.c2035_capacity.sum()} MW of {carrier} not matched")

    if nep.c2035_capacity.sum() > 0:

        # Get location using geolocator and city information
        located, unmatched = get_location(nep)

        # Bring both dataframes together
        matched = matched.append(
            located[
                [
                    "carrier",
                    "el_capacity",
                    "scenario",
                    "geometry",
                    "source",
                    "MaStRNummer",
                ]
            ],
            ignore_index=True,
        )

    # Set CRS
    matched.crs = "EPSG:4326"

    # Assign voltage level
    matched = apply_voltage_level_thresholds(matched)

    # Assign bus_id
    # Load grid district polygons
    mv_grid_districts = db.select_geodataframe(
        f"""
    SELECT * FROM {cfg['sources']['egon_mv_grid_district']}
    """,
        epsg=4326,
    )

    ehv_grid_districts = db.select_geodataframe(
        f"""
    SELECT * FROM {cfg['sources']['ehv_voronoi']}
    """,
        epsg=4326,
    )

    # Perform spatial joins for plants in ehv and hv level seperately
    power_plants_hv = gpd.sjoin(
        matched[matched.voltage_level >= 3],
        mv_grid_districts[["bus_id", "geom"]],
        how="left",
    ).drop(columns=["index_right"])
    power_plants_ehv = gpd.sjoin(
        matched[matched.voltage_level < 3],
        ehv_grid_districts[["bus_id", "geom"]],
        how="left",
    ).drop(columns=["index_right"])

    # Combine both dataframes
    power_plants = pd.concat([power_plants_hv, power_plants_ehv])

    # Delete existing units in the target table
    db.execute_sql(
        f""" DELETE FROM {cfg ['target']['schema']}.{cfg ['target']['table']}
        WHERE carrier IN ('pumped_hydro')
        AND scenario='eGon2035';"""
    )

    # If export = True export pumped_hydro plants to data base

    if export:
        # Insert into target table
        session = sessionmaker(bind=db.engine())()
        for i, row in power_plants.iterrows():
            entry = EgonStorages(
                sources={"el_capacity": row.source},
                source_id={"MastrNummer": row.MaStRNummer},
                carrier=row.carrier,
                el_capacity=row.el_capacity,
                voltage_level=row.voltage_level,
                bus_id=row.bus_id,
                scenario=row.scenario,
                geom=f"SRID=4326;POINT({row.geometry.x} {row.geometry.y})",
            )
            session.add(entry)
        session.commit()

    else:
        return power_plants


def allocate_pumped_hydro_eGon100RE():
    """Allocates pumped_hydro plants for eGon100RE scenario based on a
    prox-to-now method applied on allocated pumped-hydro plants in the eGon2035
    scenario.

    Parameters
    ----------
    None

    Returns
    -------
    None
    """

    carrier = "pumped_hydro"
    cfg = config.datasets()["power_plants"]
    boundary = config.settings()["egon-data"]["--dataset-boundary"]

    # Select installed capacity for pumped_hydro in eGon100RE scenario from
    # scenario capacities table
    capacity = db.select_dataframe(
        f"""
        SELECT capacity
        FROM {cfg['sources']['capacities']}
        WHERE carrier = '{carrier}'
        AND scenario_name = 'eGon100RE';
        """
    )

    if boundary == "Schleswig-Holstein":
        # Break capacity of pumped hydron plants down SH share in eGon2035
        capacity_phes = capacity.iat[0, 0] * 0.0176

    elif boundary == "Everything":
        # Select national capacity for pumped hydro
        capacity_phes = capacity.iat[0, 0]

    else:
        raise ValueError(f"'{boundary}' is not a valid dataset boundary.")

    # Get allocation of pumped_hydro plants in eGon2035 scenario as the reference
    # for the distribution in eGon100RE scenario
    allocation = allocate_pumped_hydro_eGon2035(export=False)

    scaling_factor = capacity_phes / allocation.el_capacity.sum()

    power_plants = allocation.copy()
    power_plants["scenario"] = "eGon100RE"
    power_plants["el_capacity"] = allocation.el_capacity * scaling_factor

    # Insert into target table
    session = sessionmaker(bind=db.engine())()
    for i, row in power_plants.iterrows():
        entry = EgonStorages(
            sources={"el_capacity": row.source},
            source_id={"MastrNummer": row.MaStRNummer},
            carrier=row.carrier,
            el_capacity=row.el_capacity,
            voltage_level=row.voltage_level,
            bus_id=row.bus_id,
            scenario=row.scenario,
            geom=f"SRID=4326;POINT({row.geometry.x} {row.geometry.y})",
        )
        session.add(entry)
    session.commit()


def home_batteries_per_scenario(scenario):
    """Allocates home batteries which define a lower boundary for extendable
    battery storage units. The overall installed capacity is taken from NEP
    for eGon2035 scenario. The spatial distribution of installed battery
    capacities is based on the installed pv rooftop capacity.

    Parameters
    ----------
    None

    Returns
    -------
    None
    """

    cfg = config.datasets()["storages"]
    dataset = config.settings()["egon-data"]["--dataset-boundary"]

    if scenario == "eGon2035":

        target_file = (
            Path(".")
            / "data_bundle_egon_data"
            / "nep2035_version2021"
            / cfg["sources"]["nep_capacities"]
        )

        capacities_nep = pd.read_excel(
            target_file,
            sheet_name="1.Entwurf_NEP2035_V2021",
            index_col="Unnamed: 0",
        )
        
    # Select target value in MW
        target = capacities_nep.Summe["PV-Batteriespeicher"]*1000

    else:
        target = db.select_dataframe(
            f"""
            SELECT capacity
            FROM {cfg['sources']['capacities']}
            WHERE scenario_name = '{scenario}'
            AND carrier = 'battery';
            """
        ).capacity[0]

    pv_rooftop = db.select_dataframe(
        f"""
        SELECT bus, p_nom, generator_id
        FROM {cfg['sources']['generators']}
        WHERE scn_name = '{scenario}'
        AND carrier = 'solar_rooftop'
        AND bus IN
            (SELECT bus_id FROM {cfg['sources']['bus']}
               WHERE scn_name = '{scenario}' AND country = 'DE' );
        """
    )

    if dataset == "Schleswig-Holstein":
        target = target / 16

    battery = pv_rooftop
    battery["p_nom_min"] = target * battery["p_nom"] / battery["p_nom"].sum()
    battery = battery.drop(columns=["p_nom"])

    battery["carrier"] = "home_battery"
    battery["scenario"] = scenario

    if scenario == "eGon2035":
        source = "NEP"

    else:
        source = "p-e-s"

    battery[
        "source"
    ] = f"{source} capacity allocated based in installed PV rooftop capacity"

    # Insert into target table
    session = sessionmaker(bind=db.engine())()
    for i, row in battery.iterrows():
        entry = EgonStorages(
            sources={"el_capacity": row.source},
            source_id={"generator_id": row.generator_id},
            carrier=row.carrier,
            el_capacity=row.p_nom_min,
            bus_id=row.bus,
            scenario=row.scenario,
        )
        session.add(entry)
    session.commit()


def allocate_pv_home_batteries():

    home_batteries_per_scenario("eGon2035")
    home_batteries_per_scenario("eGon100RE")


1		"""The central module containing all code dealing with power plant data.
2		"""
3		from geoalchemy2 import Geometry
4		from pathlib import Path
5		from sqlalchemy import BigInteger, Column, Float, Integer, Sequence, String
6		from sqlalchemy.dialects.postgresql import JSONB
7		from sqlalchemy.ext.declarative import declarative_base
8		from sqlalchemy.orm import sessionmaker
9		from egon.data.datasets.storages.pumped_hydro import (
10		select_mastr_pumped_hydro,
11		select_nep_pumped_hydro,
12		match_storage_units,
13		get_location,
14		apply_voltage_level_thresholds,
15		)
16		from egon.data.datasets.power_plants import assign_voltage_level
17		import geopandas as gpd
18		import pandas as pd
19
20		from egon.data import db, config
21		from egon.data.datasets import Dataset
22
23
24		Base = declarative_base()
25
26
27	View Code Duplication	class EgonStorages(Base):
		0 ignored issues – show Duplication introduced 2021-11-25 08:07 UTC by Report Bug Copy Issue Report This code seems to be duplicated in your project. Loading history...
28		__tablename__ = "egon_storages"
29		__table_args__ = {"schema": "supply"}
30		id = Column(BigInteger, Sequence("storage_seq"), primary_key=True)
31		sources = Column(JSONB)
32		source_id = Column(JSONB)
33		carrier = Column(String)
34		el_capacity = Column(Float)
35		bus_id = Column(Integer)
36		voltage_level = Column(Integer)
37		scenario = Column(String)
38		geom = Column(Geometry("POINT", 4326))
39
40
41		class PumpedHydro(Dataset):
42		def __init__(self, dependencies):
43		super().__init__(
44		name="Storages",
45		version="0.0.2",
46		dependencies=dependencies,
47		tasks=(
48		create_tables,
49		allocate_pumped_hydro_eGon2035,
50		allocate_pumped_hydro_eGon100RE,
51		allocate_pv_home_batteries,
52		),
53		)
54
55
56		def create_tables():
57		"""Create tables for power plant data
58		Returns
59		-------
60		None.
61		"""
62
63		cfg = config.datasets()["storages"]
64		db.execute_sql(f"CREATE SCHEMA IF NOT EXISTS {cfg['target']['schema']};")
65		engine = db.engine()
66		db.execute_sql(
67		f"""DROP TABLE IF EXISTS
68		{cfg['target']['schema']}.{cfg['target']['table']}"""
69		)
70
71		db.execute_sql("""DROP SEQUENCE IF EXISTS pp_seq""")
72		EgonStorages.__table__.create(bind=engine, checkfirst=True)
73
74
75		def allocate_pumped_hydro_eGon2035(export=True):
76		"""Allocates pumped_hydro plants for eGon2035 scenario and either exports
77		results to data base or returns as a dataframe
78
79		Parameters
80		----------
81		export : bool
82		Choose if allocated pumped hydro plants should be exported to the data
83		base. The default is True.
84		If export=False a data frame will be returned
85
86		Returns
87		-------
88		power_plants : pandas.DataFrame
89		List of pumped hydro plants in 'eGon2035' scenario
90		"""
91
92		carrier = "pumped_hydro"
93
94		cfg = config.datasets()["power_plants"]
95
96		nep = select_nep_pumped_hydro()
97		mastr = select_mastr_pumped_hydro()
98
99		# Assign voltage level to MaStR
100		mastr["voltage_level"] = assign_voltage_level(
101		mastr.rename({"el_capacity": "Nettonennleistung"}, axis=1), cfg
102		)
103
104		# Initalize DataFrame for matching power plants
105		matched = gpd.GeoDataFrame(
106		columns=[
107		"carrier",
108		"el_capacity",
109		"scenario",
110		"geometry",
111		"MaStRNummer",
112		"source",
113		"voltage_level",
114		]
115		)
116
117		# Match pumped_hydro units from NEP list
118		# using PLZ and capacity
119		matched, mastr, nep = match_storage_units(
120		nep, mastr, matched, buffer_capacity=0.1, consider_carrier=False
121		)
122
123		# Match plants from NEP list using plz,
124		# neglecting the capacity
125		matched, mastr, nep = match_storage_units(
126		nep,
127		mastr,
128		matched,
129		consider_location="plz",
130		consider_carrier=False,
131		consider_capacity=False,
132		)
133
134		# Match plants from NEP list using city,
135		# neglecting the capacity
136		matched, mastr, nep = match_storage_units(
137		nep,
138		mastr,
139		matched,
140		consider_location="city",
141		consider_carrier=False,
142		consider_capacity=False,
143		)
144
145		# Match remaining plants from NEP using the federal state
146		matched, mastr, nep = match_storage_units(
147		nep,
148		mastr,
149		matched,
150		buffer_capacity=0.1,
151		consider_location="federal_state",
152		consider_carrier=False,
153		)
154
155		# Match remaining plants from NEP using the federal state
156		matched, mastr, nep = match_storage_units(
157		nep,
158		mastr,
159		matched,
160		buffer_capacity=0.7,
161		consider_location="federal_state",
162		consider_carrier=False,
163		)
164
165		print(f"{matched.el_capacity.sum()} MW of {carrier} matched")
166		print(f"{nep.c2035_capacity.sum()} MW of {carrier} not matched")
167
168		if nep.c2035_capacity.sum() > 0:
169
170		# Get location using geolocator and city information
171		located, unmatched = get_location(nep)
172
173		# Bring both dataframes together
174		matched = matched.append(
175		located[
176		[
177		"carrier",
178		"el_capacity",
179		"scenario",
180		"geometry",
181		"source",
182		"MaStRNummer",
183		]
184		],
185		ignore_index=True,
186		)
187
188		# Set CRS
189		matched.crs = "EPSG:4326"
190
191		# Assign voltage level
192		matched = apply_voltage_level_thresholds(matched)
193
194		# Assign bus_id
195		# Load grid district polygons
196		mv_grid_districts = db.select_geodataframe(
197		f"""
198		SELECT * FROM {cfg['sources']['egon_mv_grid_district']}
199		""",
200		epsg=4326,
201		)
202
203		ehv_grid_districts = db.select_geodataframe(
204		f"""
205		SELECT * FROM {cfg['sources']['ehv_voronoi']}
206		""",
207		epsg=4326,
208		)
209
210		# Perform spatial joins for plants in ehv and hv level seperately
211		power_plants_hv = gpd.sjoin(
212		matched[matched.voltage_level >= 3],
213		mv_grid_districts[["bus_id", "geom"]],
214		how="left",
215		).drop(columns=["index_right"])
216		power_plants_ehv = gpd.sjoin(
217		matched[matched.voltage_level < 3],
218		ehv_grid_districts[["bus_id", "geom"]],
219		how="left",
220		).drop(columns=["index_right"])
221
222		# Combine both dataframes
223		power_plants = pd.concat([power_plants_hv, power_plants_ehv])
224
225		# Delete existing units in the target table
226		db.execute_sql(
227		f""" DELETE FROM {cfg ['target']['schema']}.{cfg ['target']['table']}
228		WHERE carrier IN ('pumped_hydro')
229		AND scenario='eGon2035';"""
230		)
231
232		# If export = True export pumped_hydro plants to data base
233
234		if export:
235		# Insert into target table
236		session = sessionmaker(bind=db.engine())()
237		for i, row in power_plants.iterrows():
238		entry = EgonStorages(
239		sources={"el_capacity": row.source},
240		source_id={"MastrNummer": row.MaStRNummer},
241		carrier=row.carrier,
242		el_capacity=row.el_capacity,
243		voltage_level=row.voltage_level,
244		bus_id=row.bus_id,
245		scenario=row.scenario,
246		geom=f"SRID=4326;POINT({row.geometry.x} {row.geometry.y})",
247		)
248		session.add(entry)
249		session.commit()
250
251		else:
252		return power_plants
253
254
255		def allocate_pumped_hydro_eGon100RE():
256		"""Allocates pumped_hydro plants for eGon100RE scenario based on a
257		prox-to-now method applied on allocated pumped-hydro plants in the eGon2035
258		scenario.
259
260		Parameters
261		----------
262		None
263
264		Returns
265		-------
266		None
267		"""
268
269		carrier = "pumped_hydro"
270		cfg = config.datasets()["power_plants"]
271		boundary = config.settings()["egon-data"]["--dataset-boundary"]
272
273		# Select installed capacity for pumped_hydro in eGon100RE scenario from
274		# scenario capacities table
275		capacity = db.select_dataframe(
276		f"""
277		SELECT capacity
278		FROM {cfg['sources']['capacities']}
279		WHERE carrier = '{carrier}'
280		AND scenario_name = 'eGon100RE';
281		"""
282		)
283
284		if boundary == "Schleswig-Holstein":
285		# Break capacity of pumped hydron plants down SH share in eGon2035
286		capacity_phes = capacity.iat[0, 0] * 0.0176
287
288		elif boundary == "Everything":
289		# Select national capacity for pumped hydro
290		capacity_phes = capacity.iat[0, 0]
291
292		else:
293		raise ValueError(f"'{boundary}' is not a valid dataset boundary.")
294
295		# Get allocation of pumped_hydro plants in eGon2035 scenario as the reference
296		# for the distribution in eGon100RE scenario
297		allocation = allocate_pumped_hydro_eGon2035(export=False)
298
299		scaling_factor = capacity_phes / allocation.el_capacity.sum()
300
301		power_plants = allocation.copy()
302		power_plants["scenario"] = "eGon100RE"
303		power_plants["el_capacity"] = allocation.el_capacity * scaling_factor
304
305		# Insert into target table
306		session = sessionmaker(bind=db.engine())()
307		for i, row in power_plants.iterrows():
308		entry = EgonStorages(
309		sources={"el_capacity": row.source},
310		source_id={"MastrNummer": row.MaStRNummer},
311		carrier=row.carrier,
312		el_capacity=row.el_capacity,
313		voltage_level=row.voltage_level,
314		bus_id=row.bus_id,
315		scenario=row.scenario,
316		geom=f"SRID=4326;POINT({row.geometry.x} {row.geometry.y})",
317		)
318		session.add(entry)
319		session.commit()
320
321
322		def home_batteries_per_scenario(scenario):
323		"""Allocates home batteries which define a lower boundary for extendable
324		battery storage units. The overall installed capacity is taken from NEP
325		for eGon2035 scenario. The spatial distribution of installed battery
326		capacities is based on the installed pv rooftop capacity.
327
328		Parameters
329		----------
330		None
331
332		Returns
333		-------
334		None
335		"""
336
337		cfg = config.datasets()["storages"]
338		dataset = config.settings()["egon-data"]["--dataset-boundary"]
339
340		if scenario == "eGon2035":
341
342		target_file = (
343		Path(".")
344		/ "data_bundle_egon_data"
345		/ "nep2035_version2021"
346		/ cfg["sources"]["nep_capacities"]
347		)
348
349		capacities_nep = pd.read_excel(
350		target_file,
351		sheet_name="1.Entwurf_NEP2035_V2021",
352		index_col="Unnamed: 0",
353		)
354
355		# Select target value in MW
356		target = capacities_nep.Summe["PV-Batteriespeicher"]*1000
357
358		else:
359		target = db.select_dataframe(
360		f"""
361		SELECT capacity
362		FROM {cfg['sources']['capacities']}
363		WHERE scenario_name = '{scenario}'
364		AND carrier = 'battery';
365		"""
366		).capacity[0]
367
368		pv_rooftop = db.select_dataframe(
369		f"""
370		SELECT bus, p_nom, generator_id
371		FROM {cfg['sources']['generators']}
372		WHERE scn_name = '{scenario}'
373		AND carrier = 'solar_rooftop'
374		AND bus IN
375		(SELECT bus_id FROM {cfg['sources']['bus']}
376		WHERE scn_name = '{scenario}' AND country = 'DE' );
377		"""
378		)
379
380		if dataset == "Schleswig-Holstein":
381		target = target / 16
382
383		battery = pv_rooftop
384		battery["p_nom_min"] = target * battery["p_nom"] / battery["p_nom"].sum()
385		battery = battery.drop(columns=["p_nom"])
386
387		battery["carrier"] = "home_battery"
388		battery["scenario"] = scenario
389
390		if scenario == "eGon2035":
391		source = "NEP"
392
393		else:
394		source = "p-e-s"
395
396		battery[
397		"source"
398		] = f"{source} capacity allocated based in installed PV rooftop capacity"
399
400		# Insert into target table
401		session = sessionmaker(bind=db.engine())()
402		for i, row in battery.iterrows():
403		entry = EgonStorages(
404		sources={"el_capacity": row.source},
405		source_id={"generator_id": row.generator_id},
406		carrier=row.carrier,
407		el_capacity=row.p_nom_min,
408		bus_id=row.bus,
409		scenario=row.scenario,
410		)
411		session.add(entry)
412		session.commit()
413
414
415		def allocate_pv_home_batteries():
416
417		home_batteries_per_scenario("eGon2035")
418		home_batteries_per_scenario("eGon100RE")
419

openego / eGon-data

Push — dev ( 3dcd28...416f54 )

allocate_pumped_hydro_eGon2035() B

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like