diff --git a/backend/plugins/circleci/tasks/job_collector.go b/backend/plugins/circleci/tasks/job_collector.go
index fd1d78286bf..c53ed65fbc9 100644
--- a/backend/plugins/circleci/tasks/job_collector.go
+++ b/backend/plugins/circleci/tasks/job_collector.go
@@ -60,7 +60,7 @@ func CollectJobs(taskCtx plugin.SubTaskContext) errors.Error {
 				}
 
 				if isIncremental {
-					clauses = append(clauses, dal.Where("created_date > ?", createdAfter))
+					clauses = append(clauses, dal.Where("created_at > ?", createdAfter))
 				}
 
 				db := taskCtx.GetDal()
diff --git a/backend/plugins/circleci/tasks/workflow_collector.go b/backend/plugins/circleci/tasks/workflow_collector.go
index f0f3aebe5c9..2256e28a249 100644
--- a/backend/plugins/circleci/tasks/workflow_collector.go
+++ b/backend/plugins/circleci/tasks/workflow_collector.go
@@ -61,7 +61,7 @@ func CollectWorkflows(taskCtx plugin.SubTaskContext) errors.Error {
 				}
 
 				if isIncremental {
-					clauses = append(clauses, dal.Where("created_date > ?", createdAfter))
+					clauses = append(clauses, dal.Where("created_at > ?", createdAfter))
 				}
 
 				db := taskCtx.GetDal()