async def METHOD_NAME(self):
    ran = []
    @op(conditions=[CONDITION])
    async def condition_test():
        ran.append(True)  # pragma: no cover
    async with MemoryOrchestrator() as orchestrator:
        async with orchestrator(DataFlow(condition_test)) as octx:
            async for _ in octx.run([]):
                pass
    self.assertFalse(ran)