# Store workflow definitions in git
git add automation/workflows/
git commit -m "feat: Add data sync workflow"

# Use environment-specific configurations
production:
  schedule: "0 */6 * * *"
  parallelism: 10
development:
  schedule: null  # Manual trigger only
  parallelism: 2

# Add observability to all workflows
def with_monitoring(workflow_name):
    start_time = time.time()
    try:
        result = execute_workflow()
        metrics.record_success(workflow_name, time.time() - start_time)
        return result
    except Exception as e:
        metrics.record_failure(workflow_name, str(e))
        alerts.send(f"Workflow {workflow_name} failed: {e}")
        raise

# Document workflow purpose and dependencies
# ABOUTME: Syncs customer data from CRM to data warehouse
# ABOUTME: Depends on: crm-api, warehouse-connection
# ABOUTME: Schedule: Every 6 hours