I have two flows A and B. A is parent flow and B is child flow. Both are using RayTaskRunner i.e

RayTaskRunner(
        init_kwargs={
            "num_cpus": 5,  # No. of Performance cores in M3 Pro 11 Cores
            "runtime_env": {
                "working_dir": ".",
                "excludes": ["*.pyc", "*.pyo", ".ruff_cache", ".venv", ".git", "__pycache__"],
                "worker_process_setup_hook": "backend.migrations.flows.utils.prepare_django_for_prefect",
            },
            "object_store_memory": 75 * 1024 * 1024,  # 75 MB of object store memory, we don't use it
        }
    )

B returns

ids: set[int]

.

A

keep calling

B

in a while loop until it returns an empty set. The problem is I am getting the following error 3rd time

B

is being called. Previously, it was occurring on 2nd time

AssertionError: The env var, __RAY_WORKER_PROCESS_SETUP_HOOK_ENV_VAR, is not permitted because it is reserved for the internal use.

What could be the issue here?