Workflows

from unstructured import UnstructuredClient

client = UnstructuredClient(
    base_url="https://unstructured.your-company.com/rest/unstructured",
    username="your-username",
    password="your-password",
)

# Nightly ingest + classify pipeline (same shape the web UI creates)
result = client.workflows.upsert(
    workflow={
        "name": "Nightly prepare: contracts",
        "description": "Ingest new documents and re-classify every night",
        "cadence": "0 0 * * *",  # cron expression
        "stages": [
            {
                "jobs": [
                    {
                        "endpoint": "/ocr/ingest",
                        "endpoint_request_body": {
                            "data_connector_name": "my-s3-bucket",
                        },
                    },
                ],
            },
            {
                "jobs": [
                    {
                        "endpoint": "/classify_bulk",
                        "endpoint_request_body": {
                            "data_connector_name": "my-s3-bucket",
                        },
                    },
                ],
            },
        ],
    },
)