diff --git a/worker/job_feed_daemon_status.go b/worker/job_feed_daemon_status.go index 0973928..2a6f7f7 100644 --- a/worker/job_feed_daemon_status.go +++ b/worker/job_feed_daemon_status.go @@ -213,7 +213,7 @@ func (d *jobFeedDaemonStatus) dbCheckClusterIDForNodeID(ctx context.Context) err } func (d *jobFeedDaemonStatus) dbCheckClusters(ctx context.Context) error { - if err := d.oDb.UpdateClustersData(ctx, d.clusterName, d.clusterName, string(d.rawData)); err != nil { + if err := d.oDb.UpdateClustersData(ctx, d.clusterName, d.clusterID, string(d.rawData)); err != nil { return fmt.Errorf("dbCheckClusters %s (%s): %w", d.nodeID, d.clusterID, err) } return nil