counterweight/data-xexe
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

it's all pairs

Browse source
This commit is contained in:
Pablo Martin 2025-05-26 16:41:49 +02:00
parent aba2920a70
commit b52af85987
1 changed files with 9 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

21
xexe/processes.py
View file

@ -1,6 +1,7 @@
import logging import logging
import os import os
import pathlib import pathlib
from itertools import combinations
from typing import List, Set, Union from typing import List, Set, Union
from money.currency import Currency from money.currency import Currency
@ -11,11 +12,7 @@ from xexe.currency_pair import CurrencyPair
from xexe.exchange_rates import ExchangeRates, add_equal_rates, add_inverse_rates from xexe.exchange_rates import ExchangeRates, add_equal_rates, add_inverse_rates
from xexe.rate_fetching import build_rate_fetcher from xexe.rate_fetching import build_rate_fetcher
from xexe.rate_writing import build_rate_writer from xexe.rate_writing import build_rate_writer
from xexe.utils import ( from xexe.utils import DateRange, generate_pairs_and_dates_combinations
DateRange,
generate_currency_and_dates_combinations,
generate_pairs_and_dates_combinations,
)
logger = logging.getLogger() logger = logging.getLogger()
@ -84,14 +81,14 @@ def run_get_rates(
process_state = GetRatesProcessState(ignore_warnings=ignore_warnings) process_state = GetRatesProcessState(ignore_warnings=ignore_warnings)
if currencies: if currencies:
currency_and_date_combinations = generate_currency_and_dates_combinations( pairs = list(combinations(currencies, 2))
date_range=date_range, currencies=currencies pairs = [
) CurrencyPair(from_currency=pair[0], to_currency=pair[1]) for pair in pairs
]
if pairs: currency_and_date_combinations = generate_pairs_and_dates_combinations(
currency_and_date_combinations = generate_pairs_and_dates_combinations( date_range=date_range, pairs=pairs
date_range=date_range, pairs=pairs )
)
rates = obtain_rates_from_source( rates = obtain_rates_from_source(
rates_source=rates_source, rates_source=rates_source,