diff --git a/services/scheduler/db/describe.go b/services/scheduler/db/describe.go index f75bb8898..bccc2c759 100644 --- a/services/scheduler/db/describe.go +++ b/services/scheduler/db/describe.go @@ -117,7 +117,7 @@ func (db Database) GetLastDescribeIntegrationJob(integrationId, resourceType str // Query with JSONB condition tx := db.ORM.Preload(clause.Associations). - Where("integration_id = ? AND resource_type = ? AND parameters @> ?", integrationId, resourceType, parametersBytes). + Where("integration_id = ? AND resource_type = ? AND convert_from(parameters, 'UTF8')::JSONB @> ?::JSONB", integrationId, resourceType, parametersBytes). Order("updated_at DESC"). First(&job)