We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see ourdocumentation.
There was an error while loading.Please reload this page.
1 parentba2f90a commit74f5dd7Copy full SHA for 74f5dd7
enterprise/coderd/prebuilds/reconcile.go
@@ -103,8 +103,12 @@ func (c *StoreReconciler) Run(ctx context.Context) {
103
c.running.Store(true)
104
105
// Publish provisioning jobs outside of database transactions.
106
-// PGPubsub tries to acquire a new connection on Publish. A connection is held while a database transaction is active,
107
-// so we can exhaust available connections.
+// A connection is held while a database transaction is active; PGPubsub also tries to acquire a new connection on
+// Publish, so we can exhaust available connections.
108
+//
109
+// A single worker dequeues from the channel, which should be sufficient.
110
+// If any messages are missed due to congestion or errors, provisionerdserver has a backup polling mechanism which
111
+// will periodically pick up any queued jobs (see poll(time.Duration) in coderd/provisionerdserver/acquirer.go).
112
gofunc() {
113
for {
114
select {