Feed inputs to get_forks so fork factory can use algo input data (#129)

esd_services_api_client/nexus/algorithms/forked_algorithm.py

@@ -143,8 +143,13 @@ async def _measured_run(**run_args) -> AlgorithmResult:
 
             return await self._main_run(**run_args)
 
+        if self._is_forked(**kwargs):
+            self._inputs = await self._fork_inputs(**kwargs)
+        else:
+            self._inputs = await self._main_inputs(**kwargs)
+
         # evaluate if additional forks will be spawned
-        forks = await self._get_forks(**kwargs)
+        forks = await partial(self._get_forks, **self._inputs, **kwargs)()
 
         if len(forks) > 0:
             self._logger.info(
@@ -154,11 +159,6 @@ async def _measured_run(**run_args) -> AlgorithmResult:
         else:
             self._logger.info("Leaf algorithm node: proceeding with this node run only")
 
-        if self._is_forked(**kwargs):
-            self._inputs = await self._fork_inputs(**kwargs)
-        else:
-            self._inputs = await self._main_inputs(**kwargs)
-
         run_result = await partial(
             _measured_run,
             **self._inputs,