[19.0] queue_job: Jobs stay pending after the jobrunner's database connection is silently dropped
Mantenedores costumam responder em até 1 dia
Avaliação
- Dificuldade
- 2/5
- Tempo estimado
- 1-3 horas
- Facilidade para iniciantes
- 25/100
Direção de pesquisa
The issue points to queue_job/jobrunner/runner.py, specifically _connection_info_for() and QueueJobRunner.run(). Review how connection parameters are assembled and how the runner handles a lost connection; the issue proposes enabling TCP keepalives with defaults. An open linked pull request already addresses this issue, so check that work before making changes.
Escrita pelo modelo de indexação a partir do texto da issue.
Descrição
Module
- queue_job
Describe the bug
The jobrunner keeps one database connection open for as long as it runs, and it holds
the master lock on that connection.
If that connection dies without the server telling the client (a network problem, or a
database failover), two things happen:
- PostgreSQL drops the lock, because the session is gone.
- The runner does not notice. Its socket still looks open, so it just waits forever.
From then on no jobs are dispatched at all. Nothing is logged. The process looks healthy.
Only restarting Odoo fixes it.
The runner already has code to reconnect if the database connection breaks (the
except Exception block in run()), but it never runs, because nothing raises an error.
The runner is simply stuck waiting.
To Reproduce
Affected versions: 19.0
Steps to reproduce the behavior:
- Start Odoo with
queue_jobinserver_wide_modules(odoo.conf). Check the runner has the lock:
SELECT count(*) FROM pg_locks WHERE locktype = 'advisory';should return 1. - Break the connection silently, so the client is never told. For example, add a firewall
rule that drops traffic between Odoo and PostgreSQL. (Usingpg_terminate_backendwill
not work, because that tells the client.) - Add a job. It stays
pendingforever. The lock count is now 0, and nothing appears in
the log.
Expected behavior
The runner should notice the connection is dead and reconnect, which is what the
except Exception block is already there to do.
zooming in to the except Exception mentioned:
QueueJobRunner.run() in queue_job/jobrunner/runner.py.
The outer loop wraps initialize_databases() and the processing loop in a try/except,
and the last of its four handlers is:
except Exception:
_logger.exception("exception: sleeping %ds and retrying", ERROR_RECOVERY_DELAY)
self.close_databases()
time.sleep(ERROR_RECOVERY_DELAY)
Additional context
- Running Odoo in AWS ECS and Aurora PostgreSQL.
- Odoo WEB service and CRON service separated
- Both web and cron service has server_wide_modules = queue_job
- cron service has http_enable = False and runs on a different port
Proposed Fix:
In queue_job/jobrunner/runner.py, at the end of
_connection_info_for(), just before the return:
# added
connection_info.setdefault("keepalives", 1)
connection_info.setdefault("keepalives_idle", 60)
connection_info.setdefault("keepalives_interval", 10)
connection_info.setdefault("keepalives_count", 5)
The fix is to turn on TCP keepalives there, so a dead connection is noticed after about a
minute instead of never.
- Linguagem predominante
- Python
- Estrelas
- 271
- Forks
- 602
- Merge médio
- 4d 4h
- PRs com merge (30d)
- 6
Preparar o ambiente
- Sem Dockerfile nem arquivo Docker Compose
- Sem modelo de pull request
- Ler o guia de contribuição
Primeiros passos
- Leia a issue inteira e depois o guia de contribuição do projeto.
- Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
- Faça um fork do repositório e trabalhe em uma branch.
- Abra um pull request que referencie o número da issue.
Mais de OCA/queue
-
enhancement
Dificuldade 3/5 1-2 dias Facilidade para iniciantes 30/100
Mantenedores costumam responder em até 1 dia
-
Migration to version 20.0Abertahelp wanted no stale work in progress
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 35/100
OCA/queue#1002 · 2 comentários ·
Mantenedores costumam responder em até 1 dia
-
Delaying unlink or write on a model whose method was replaced raises AttributeError at enqueue timeTalvez já em andamento Um pull request vinculado a esta issue está aberto ou já foi mesclado. Abertabug
Dificuldade 4/5 3-5 dias Facilidade para iniciantes 35/100
Mantenedores costumam responder em até 1 dia
-
enhancement
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 35/100
Mantenedores costumam responder em até 1 dia
-
enhancement
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 35/100
OCA/queue#964 · 1 comentário · 1 reação ·
Mantenedores costumam responder em até 1 dia
Issues semelhantes
-
Release notes from PR titlesAberta
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 72/100
-
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 78/100
Mantenedores costumam responder em até 1 dia
-
[DATA] BDC portfolio DataFrame converts filed zero fair value and principal to missing valuesAbertabug
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 74/100
dgunning/edgartools#1853 ·
Mantenedores costumam responder em até 1 dia
-
Dificuldade 1/5 Menos de uma hora Facilidade para iniciantes 80/100
Imbad0202/academic-research-skills#1039 ·
Mantenedores costumam responder em até 1 dia
-
Dificuldade 1/5 Menos de uma hora Facilidade para iniciantes 82/100
openmainframeproject/feilong#980 ·
Mantenedores costumam responder em até 5 dias