File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1515 "btc" ,
1616 "pl_banking_stocks" ,
1717 "sunspots" ,
18- "geomagnetic_activity"
18+ "geomagnetic_activity" ,
19+ "world_bank_oil_gold_monthly_prices"
1920]
2021
2122
@@ -80,6 +81,13 @@ def _load_geomagnetic_activity() -> pd.DataFrame:
8081 ))
8182
8283
84+ def _load_world_bank_oil_gold_monthly_prices () -> pd .DataFrame :
85+ return pd .read_parquet (str (
86+ resources .files ('moddata.data' ).joinpath (
87+ 'world_bank_oil_gold_monthly_prices.parquet' )
88+ ))
89+
90+
8391def load_data (dataset : Dataset ) -> pd .DataFrame | None :
8492 if dataset == "bankchurn" :
8593 return _load_bankchurn ()
@@ -92,5 +100,5 @@ def load_data(dataset: Dataset) -> pd.DataFrame | None:
92100 if dataset == "geomagnetic_activity" :
93101 return _load_geomagnetic_activity ()
94102 if dataset == "world_bank_oil_gold_monthly_prices" :
95- raise NotImplementedError
103+ return _load_world_bank_oil_gold_monthly_prices ()
96104 raise ValueError (f"Encountered invalid dataset name: { dataset } " )
Original file line number Diff line number Diff line change @@ -46,7 +46,3 @@ def run(self):
4646 "world_bank_oil_gold_monthly_prices.parquet"
4747 )
4848 )
49-
50-
51- if __name__ == "__main__" :
52- OilGoldMonthlyPricesPipeline ().run ()
You can’t perform that action at this time.
0 commit comments