self.market.report.log_stage("{}_begin".format(process_name))
if "fetch_balances_begin" in step:
- self.market.balances.fetch_balances(tag="{}_begin".format(process_name),
- **step["fetch_balances_begin"])
+ self.run_action("fetch_balances", step["fetch_balances_begin"],
+ dict(options, tag="{}_begin".format(process_name)))
for action in self.ordered_actions:
if action in step:
self.run_action(action, step[action], options)
if "fetch_balances_end" in step:
- self.market.balances.fetch_balances(tag="{}_end".format(process_name),
- **step["fetch_balances_end"])
+ self.run_action("fetch_balances", step["fetch_balances_end"],
+ dict(options, tag="{}_end".format(process_name)))
self.market.report.log_stage("{}_end".format(process_name))
method = self.market.trades.close_trades
elif action == "print_tickers":
method = self.market.print_tickers
+ elif action == "fetch_balances":
+ method = self.market.balances.fetch_balances
signature = inspect.getfullargspec(method)
defaults = signature.defaults or []