"name": "print_balances",
"number": 1,
"fetch_balances": ["begin"],
+ "fetch_balances_args": { "add_portfolio": True },
"print_tickers": { "base_currency": "BTC" },
}
],
def process_step(self, scenario_name, step, kwargs):
process_name = "process_{}__{}_{}".format(scenario_name, step["number"], step["name"])
self.market.report.log_stage("{}_begin".format(process_name))
+
+ fetch_args = step.get("fetch_balances_args", {})
if "begin" in step.get("fetch_balances", []):
- self.market.balances.fetch_balances(tag="{}_begin".format(process_name), log_tickers=True)
+ self.market.balances.fetch_balances(tag="{}_begin".format(process_name),
+ log_tickers=True, **fetch_args)
for action in self.ordered_actions:
if action in step:
self.run_action(action, step[action], kwargs)
if "end" in step.get("fetch_balances", []):
- self.market.balances.fetch_balances(tag="{}_end".format(process_name), log_tickers=True)
+ self.market.balances.fetch_balances(tag="{}_end".format(process_name),
+ log_tickers=True, **fetch_args)
self.market.report.log_stage("{}_end".format(process_name))
def method_arguments(self, action):