Module import errors while using Redis sampler

[PrachetaBA]

Hi, I'm facing an import error while using the Redis sampler and I was hoping to get some insight into why it is happening. My code is structured in the following manner

- project
- __init_.py
- src
    - __init__.py
    - simulator.py
    - pyabc_pipeline.py
    - ...

While running the script python -m src.pyabc_pipeline, I get the following error

ABC.Sampler INFO: Start redis worker. Max run time 7200.0s, HOST=<host_name>, PID=2076649
ABC.Sampler INFO: Subscribed to host 127.0.0.1 port 6379
ABC.Sampler INFO: Begin generation -1, I am worker 1
Traceback (most recent call last):
  File "/.conda/envs/sbi_env/bin/abc-redis-worker", line 8, in <module>
    sys.exit(work())
  File "/.conda/envs/sbi_env/lib/python3.10/site-packages/click/core.py", line 1157, in __call__
    return self.main(*args, **kwargs)
  File "/.conda/sbi_env/lib/python3.10/site-packages/click/core.py", line 1078, in main
    rv = self.invoke(ctx)
  File "/.conda/envs/sbi_env/lib/python3.10/site-packages/click/core.py", line 1434, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "/.conda/envs/sbi_env/lib/python3.10/site-packages/click/core.py", line 783, in invoke
    return __callback(*args, **kwargs)
  File "/.conda/envs/sbi_env/lib/python3.10/site-packages/pyabc/sampler/redis_eps/cli.py", line 89, in work
    return _work(host, port, runtime, password, catch)
  File "/.conda/envs/sbi_env/lib/python3.10/site-packages/pyabc/sampler/redis_eps/cli.py", line 174, in _work
    work_on_population_dynamic(
  File "/.conda/envs/sbi_env/lib/python3.10/site-packages/pyabc/sampler/redis_eps/work.py", line 87, in work_on_population_dynamic
    simulate_one, sample_factory = pickle.loads(ssa_b)
  File "/.conda/envs/sbi_env/lib/python3.10/site-packages/cloudpickle/cloudpickle.py", line 461, in subimport
    __import__(name)
ModuleNotFoundError: No module named 'src'

I'm unable to find any pointers online to pinpoint the source of this issue and it only occurs when I'm using the distributed sampler. I appreciate any pointers to debug this.

[stephanmg]

Hi @PrachetaBA - could you provide more details? This Python 3.10 on which OS?