Function _sync_batch_payload

tests/connect/test_sync.py:18–37

(
    batch_id: uuid.UUID,
    *,
    import_and_commit: bool = False,
    state: str = "SYNCING",
    syncs: list[dict],
    all_syncs_succeeded: bool | None = None,
    error_message: str | None = None,
)

def _sync_batch_payload(
    batch_id: uuid.UUID,
    *,
    import_and_commit: bool = False,
    state: str = "SYNCING",
    syncs: list[dict],
    all_syncs_succeeded: bool | None = None,
    error_message: str | None = None,
) -> dict:
    payload = dict(
        id=str(batch_id),
        import_and_commit=import_and_commit,
        state=state,
        syncs=syncs,
    )
    if all_syncs_succeeded is not None:
        payload["all_syncs_succeeded"] = all_syncs_succeeded
    if error_message is not None:
        payload["error_message"] = error_message
    return payload


def _mock_list_repo(