single point of xfer

robcarver17 · Nov 17, 2023 · 568c13e · 568c13e
1 parent 22f2433
commit 568c13e
Show file tree

Hide file tree

Showing 8 changed files with 13 additions and 11 deletions.
diff --git a/sysdata/pointers.py b/sysdata/pointers.py
@@ -0,0 +1,4 @@
+from sysdata.parquet.parquet_adjusted_prices import parquetFuturesAdjustedPricesData
+from sysdata.arctic.arctic_adjusted_prices import arcticFuturesAdjustedPricesData
+
+parquetFuturesAdjustedPricesData = parquetFuturesAdjustedPricesData ## change to arctic if desired
diff --git a/sysdata/sim/db_futures_sim_data.py b/sysdata/sim/db_futures_sim_data.py
@@ -5,7 +5,7 @@
 
 from syscore.constants import arg_not_supplied
 
-from sysdata.parquet.parquet_adjusted_prices import parquetFuturesAdjustedPricesData
+from sysdata.pointers import parquetFuturesAdjustedPricesData
 from sysdata.arctic.arctic_multiple_prices import arcticFuturesMultiplePricesData
 from sysdata.arctic.arctic_spotfx_prices import arcticFxPricesData
 from sysdata.csv.csv_instrument_data import csvFuturesInstrumentData

diff --git a/sysinit/futures/adjustedprices_from_mongo_multiple_to_mongo.py b/sysinit/futures/adjustedprices_from_mongo_multiple_to_mongo.py
@@ -6,7 +6,7 @@
 """
 from syscore.constants import arg_not_supplied
 from sysdata.arctic.arctic_multiple_prices import arcticFuturesMultiplePricesData
-from sysdata.parquet.parquet_adjusted_prices import parquetFuturesAdjustedPricesData
+from sysdata.pointers import parquetFuturesAdjustedPricesData
 from sysdata.csv.csv_adjusted_prices import csvFuturesAdjustedPricesData
 
 from sysobjects.adjusted_prices import futuresAdjustedPrices

diff --git a/sysinit/futures/clone_data_for_instrument.py b/sysinit/futures/clone_data_for_instrument.py
@@ -2,8 +2,7 @@
     arcticFuturesContractPriceData,
 )
 from sysdata.arctic.arctic_multiple_prices import arcticFuturesMultiplePricesData
-from sysdata.parquet.parquet_adjusted_prices import parquetFuturesAdjustedPricesData
-
+from sysdata.pointers import parquetFuturesAdjustedPricesData
 from sysdata.csv.csv_roll_calendars import csvRollCalendarData
 from sysdata.csv.csv_multiple_prices import csvFuturesMultiplePricesData
 from sysdata.csv.csv_adjusted_prices import csvFuturesAdjustedPricesData

diff --git a/sysinit/futures/multiple_and_adjusted_from_csv_to_arctic.py b/sysinit/futures/multiple_and_adjusted_from_csv_to_arctic.py
@@ -2,7 +2,7 @@
 from sysdata.csv.csv_multiple_prices import csvFuturesMultiplePricesData
 from sysdata.csv.csv_adjusted_prices import csvFuturesAdjustedPricesData
 from sysdata.arctic.arctic_multiple_prices import arcticFuturesMultiplePricesData
-from sysdata.parquet.parquet_adjusted_prices import parquetFuturesAdjustedPricesData
+from sysdata.pointers import parquetFuturesAdjustedPricesData
 
 def init_arctic_with_csv_futures_contract_prices(
     multiple_price_datapath=arg_not_supplied, adj_price_datapath=arg_not_supplied

diff --git a/sysinit/futures/repocsv_adjusted_prices.py b/sysinit/futures/repocsv_adjusted_prices.py
@@ -2,7 +2,7 @@
 Copy from csv repo files to arctic for adjusted prices
 """
 from syscore.constants import arg_not_supplied
-from sysdata.parquet.parquet_adjusted_prices import parquetFuturesAdjustedPricesData
+from sysdata.pointers import parquetFuturesAdjustedPricesData
 from sysdata.csv.csv_adjusted_prices import csvFuturesAdjustedPricesData
 
 if __name__ == "__main__":

diff --git a/sysproduction/backup_arctic_to_csv.py b/sysproduction/backup_arctic_to_csv.py
@@ -28,7 +28,7 @@
     arcticFuturesContractPriceData,
 )
 from sysdata.arctic.arctic_multiple_prices import arcticFuturesMultiplePricesData
-from sysdata.parquet.parquet_adjusted_prices import parquetFuturesAdjustedPricesData
+from sysdata.pointers import parquetFuturesAdjustedPricesData
 from sysdata.arctic.arctic_spotfx_prices import arcticFxPricesData
 from sysdata.arctic.arctic_spreads import arcticSpreadsForInstrumentData
 from sysdata.arctic.arctic_capital import arcticCapitalData

diff --git a/sysproduction/data/prices.py b/sysproduction/data/prices.py
@@ -21,10 +21,9 @@
     arcticFuturesMultiplePricesData,
     futuresMultiplePrices,
 )
-from sysdata.parquet.parquet_adjusted_prices import (
-    parquetFuturesAdjustedPricesData,
-    futuresAdjustedPrices,
-)
+from sysdata.pointers import parquetFuturesAdjustedPricesData
+from sysobjects.adjusted_prices import futuresAdjustedPrices
+
 from sysdata.arctic.arctic_spreads import (
     arcticSpreadsForInstrumentData,
     spreadsForInstrumentData,