diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index 017ec61..feeab9e 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -322,7 +322,7 @@ where backid=${backid}$ 'ctx': ctx, 'node': node } - on_array = await self.get_multiple_array(m_on): + on_array = await self.get_multiple_array(m_on) for e in on_array: nnodes.add((edge['to'], str(e))) for node, ctx_ext in nnodes: