fix to disable cloud option

Author: stephengpope

app.py

@@ -100,9 +100,6 @@ def wrapper(*args, **kwargs):
                 # Use _cloud_job_id from payload if available (for cloud jobs), otherwise generate new UUID
                 job_id = data.pop('_cloud_job_id', None) or str(uuid.uuid4())
 
-                # Extract disable_cloud_job from payload for conditional logic and remove it
-                # to prevent validation errors in all processing modes
-                disable_cloud_job = data.pop('disable_cloud_job', None)
 
                 pid = os.getpid()  # Get PID for non-queued tasks
                 start_time = time.time()
@@ -157,7 +154,7 @@ def wrapper(*args, **kwargs):
 
                     return response_obj, response[2]
 
-                if os.environ.get("GCP_JOB_NAME") and data.get("webhook_url") and not disable_cloud_job:
+                if os.environ.get("GCP_JOB_NAME") and data.get("webhook_url") and not data.get("disable_cloud_job"):
                     try:
                         # Create enhanced payload with original job_id for cloud jobs
                         cloud_payload = data.copy()

app_utils.py

@@ -31,10 +31,11 @@ def decorated_function(*args, **kwargs):
             if not request.json:
                 return jsonify({"message": "Missing JSON in request"}), 400
 
-            # Create a copy of the request data and remove internal _cloud_job_id field
-            # to prevent validation errors while preserving it for cloud job processing
+            # Create a copy of the request data and remove internal _cloud_job_id and disable_cloud_job fields
+            # to prevent validation errors while preserving them for processing
             validation_data = request.json.copy()
             validation_data.pop('_cloud_job_id', None)
+            validation_data.pop('disable_cloud_job', None)
 
             try:
                 jsonschema.validate(instance=validation_data, schema=schema)