FlexMeasures / flexmeasures / 41727551109

88%

Build Type

push

github

Committed by web-flow

Commit Message

Give each forked job process its own database connections (#2808)

* Give each forked job process its own database connections

RQ's Worker forks a process per job, and the fork copied the worker's connection pool, sockets included,
so every job talked to Postgres over the worker's own session.
A forecast cycle job that saved beliefs exited with that session still in a transaction,
and the next job's first query failed in the connection pool's pre-ping with
"can't change 'autocommit' now: connection in transaction status INTRANS".

The worker now gives up its connections before it starts,
and each forked process replaces its inherited pool without closing the parent's sockets.

Fixes #2806

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_018LLkbRG5EsFm79Ff9pVAMs
Signed-off-by: F.N. Claessen <claessen@seita.nl>

* Changelog: jobs no longer fail after one that saved data on the same worker

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_018LLkbRG5EsFm79Ff9pVAMs
Signed-off-by: F.N. Claessen <claessen@seita.nl>

* Fork tests: decode the pipe as UTF-8, and skip where the worker does not fork

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_018LLkbRG5EsFm79Ff9pVAMs
Signed-off-by: F.N. Claessen <claessen@seita.nl>

* Docker image: read config and secrets mounted at /app/instance again

Since FlexMeasures is installed non-editable in the image (#2512), Flask places its instance folder at
${VIRTUAL_ENV}/var/flexmeasures-instance, so a flexmeasures.cfg mounted at /app/instance, as the Docker docs say, went unread.
In the QA workflow, this left the server out of play mode, and HEMS ran into the trigger rate limit.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_018LLkbRG5EsFm79Ff9pVAMs
Signed-off-by: F.N. Claessen <claessen@seita.nl>

* QA: fai... (continued)

Coverage Stats

7 of 8 new or added lines in 1 file covered. (87.5%)

1 existing line in 1 file now uncovered.

23081 of 26320 relevant lines covered (87.69%)

0.88 hits per line