Closed ianstanton closed 2 months ago
Update queue.create() in conductor metrics reporter to queue.create_partitioned(). This has been causing a race condition issue in initial Self Hosted installations: https://linear.app/tembo/issue/SLF-32/handle-race-condition-between-control-plane-and-conductor.
queue.create()
queue.create_partitioned()
This is one of 3 places where we have code to create this queue, so we could potentially remove this line here. We also create this queue in:
Update
queue.create()
in conductor metrics reporter toqueue.create_partitioned()
. This has been causing a race condition issue in initial Self Hosted installations: https://linear.app/tembo/issue/SLF-32/handle-race-condition-between-control-plane-and-conductor.This is one of 3 places where we have code to create this queue, so we could potentially remove this line here. We also create this queue in: