always be syncing

PostHog · Nov 15, 2023 · 2a69b70 · 2a69b70
1 parent 8112ac5
commit 2a69b70
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/posthog/tasks/warehouse.py b/posthog/tasks/warehouse.py
@@ -22,7 +22,7 @@
 
 
 def sync_resources() -> None:
-    resources = ExternalDataSource.objects.filter(are_tables_created=False, status__in=["running", "error"])
+    resources = ExternalDataSource.objects.filter(status__in=["running", "error"])
 
     for resource in resources:
         sync_resource.delay(resource.pk)
@@ -83,14 +83,10 @@ def sync_resource(resource_id: str) -> None:
             )
         else:
             table.save()
-
             resource.are_tables_created = True
-            resource.status = job["status"]
-            resource.save()
 
-    else:
-        resource.status = job["status"]
-        resource.save()
+    resource.status = job["status"]
+    resource.save()
 
 
 DEFAULT_USAGE_LIMIT = 1000000