add schema off check

posthog/temporal/data_imports/external_data_job.py

@@ -32,6 +32,7 @@
     ExternalDataJob,
     get_active_schemas_for_source_id,
     ExternalDataSource,
+    aget_schema_by_id,
 )
 from posthog.temporal.common.logger import bind_temporal_worker_logger
 from typing import Dict
@@ -119,6 +120,12 @@ async def check_schedule_activity(inputs: ExternalDataWorkflowInputs) -> bool:
         logger.info(f"Deleted schedule for source {inputs.external_data_source_id}")
         return True
 
+    schema_model = await aget_schema_by_id(inputs.external_data_schema_id, inputs.team_id)
+
+    # schema turned off so don't sync
+    if schema_model and not schema_model.should_sync:
+        return True
+
     logger.info("Schema ID is set. Continuing...")
     return False