Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

BrokenPipeError: [Errno 32] Broken pipe #96

Open
SDFlying858 opened this issue Mar 13, 2024 · 0 comments
Open

BrokenPipeError: [Errno 32] Broken pipe #96

SDFlying858 opened this issue Mar 13, 2024 · 0 comments

Comments

@SDFlying858
Copy link

Hello,

I'm attempting to use the optstrategy functionality to optimize my algorithm using an Orange Pi 5 Plus running Ubuntu OS.

My script functions properly when run with only a few variations such as below

strats = cerebro.optstrategy(
            IndicatorResearch,
            period1 = range(1, 3),
            period2 = range(15, 18),
            rsibuy = range (30, 35),
            rsisell = range(60, 65),
    )

It fails when more variations are introduced:

strats = cerebro.optstrategy(
            IndicatorResearch,
            period1 = range(1, 15),
            period2 = range(15, 25  ),
            rsibuy = range (16, 46),
            rsisell = range(56, 76),
    )

When it fails the errors I get for each pool worker are:

Process ForkPoolWorker-2:
Traceback (most recent call last):
  File "/usr/lib/python3.10/multiprocessing/pool.py", line 131, in worker
    put((job, i, result))
  File "/usr/lib/python3.10/multiprocessing/queues.py", line 377, in put
    self._writer.send_bytes(obj)
  File "/usr/lib/python3.10/multiprocessing/connection.py", line 200, in send_bytes
    self._send_bytes(m[offset:offset + size])
  File "/usr/lib/python3.10/multiprocessing/connection.py", line 404, in _send_bytes
    self._send(header)
  File "/usr/lib/python3.10/multiprocessing/connection.py", line 368, in _send
    n = write(self._handle, buf)
BrokenPipeError: [Errno 32] Broken pipe

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/usr/lib/python3.10/multiprocessing/process.py", line 314, in _bootstrap
    self.run()
  File "/usr/lib/python3.10/multiprocessing/process.py", line 108, in run
    self._target(*self._args, **self._kwargs)
  File "/usr/lib/python3.10/multiprocessing/pool.py", line 136, in worker
    put((job, i, (False, wrapped)))
  File "/usr/lib/python3.10/multiprocessing/queues.py", line 377, in put
    self._writer.send_bytes(obj)
  File "/usr/lib/python3.10/multiprocessing/connection.py", line 200, in send_bytes
    self._send_bytes(m[offset:offset + size])
  File "/usr/lib/python3.10/multiprocessing/connection.py", line 411, in _send_bytes
    self._send(header + buf)
  File "/usr/lib/python3.10/multiprocessing/connection.py", line 368, in _send
    n = write(self._handle, buf)
BrokenPipeError: [Errno 32] Broken pipe

I'm having trouble understanding what connection is failing, all file reading occurs on the local drive.

Thanks.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant