def mock_dicts(mock_sync_job_id):
    """Create all required mock dictionaries for the workflow."""
    return {
        "sync_dict": {
            "id": str(uuid4()),
            "name": "Test Sync",
            "created_at": datetime.now().isoformat(),
            "updated_at": datetime.now().isoformat(),
        },
        "sync_job_dict": {
            "id": mock_sync_job_id,
            "sync_id": str(uuid4()),
            "status": "CREATED",
            "created_at": datetime.now().isoformat(),
            "updated_at": datetime.now().isoformat(),
        },
        "sync_dag_dict": {"id": str(uuid4()), "nodes": [], "edges": []},
        "collection_dict": {"id": str(uuid4()), "name": "Test Collection"},
        "source_connection_dict": {"id": str(uuid4()), "name": "Test Connection"},
        "user_dict": {
            "id": str(uuid4()),
            "email": "test@example.com",
            "created_at": datetime.now().isoformat(),
            "updated_at": datetime.now().isoformat(),
        },
    }
Create all required mock dictionaries for the workflow.
backend/tests/integration/temporal/test_workflow_cancellation.py