{"record":{"id":"b2a35110c65e250a","repo":"pathwaycom/pathway","slug":"all-streams-within-the-same-pw-io-airbyte-read-m","errorCode":null,"errorMessage":"All streams within the same 'pw.io.airbyte.read' must have the same 'sync_mode'","messagePattern":"All streams within the same 'pw\\.io\\.airbyte\\.read' must have the same 'sync_mode'","errorType":"validation","errorClass":"ValueError","httpStatus":null,"severity":"error","filePath":"python/pathway/io/airbyte/__init__.py","lineNumber":100,"sourceCode":"    else:\n        logging.info(f\"Running connector {connector_name} as a Docker image\")\n        source = DockerAirbyteSource(\n            connector=source_config[\"docker_image\"],\n            config=source_config.get(\"config\"),\n            streams=streams,\n            env_vars=copy.copy(env_vars),\n        )\n\n    # Run airbyte connector locally and check streams\n    global_sync_mode = None\n    for stream in source.configured_catalog[\"streams\"]:\n        name = stream[\"stream\"][\"name\"]\n        sync_mode = stream[\"sync_mode\"]\n        if sync_mode != INCREMENTAL_SYNC_MODE and sync_mode != FULL_REFRESH_SYNC_MODE:\n            raise ValueError(f\"Stream {name} has unknown sync_mode: {sync_mode}\")\n        global_sync_mode = global_sync_mode or sync_mode\n        if global_sync_mode != sync_mode:\n            raise ValueError(\n                \"All streams within the same 'pw.io.airbyte.read' must have \"\n                \"the same 'sync_mode'\"\n            )\n\n    return source\n\n\nclass _AirbyteRecordSchema(Schema):\n    data: dict\n\n\ndef read(\n    config_file_path: os.PathLike | str,\n    streams: Sequence[str],\n    *,\n    execution_type: str = \"local\",\n    mode: Literal[\"streaming\", \"static\"] = \"streaming\",\n    env_vars: dict[str, str] | None = None,","sourceCodeStart":82,"sourceCodeEnd":118,"githubUrl":"https://github.com/pathwaycom/pathway/blob/fa2f74a4649b7c5908690cf60137263d8d80de5f/python/pathway/io/airbyte/__init__.py#L82-L118","documentation":"Error \"All streams within the same 'pw.io.airbyte.read' must have the same 'sync_mode'\" thrown in pathwaycom/pathway.","triggerScenarios":"Thrown at python/pathway/io/airbyte/__init__.py:100 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Use the same sync_mode for all streams of one pw.io.airbyte.read call, or split streams with different modes into separate reads."],"exampleFix":"pw.io.airbyte.read(config_streams_with_same_sync_mode)","handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"fa2f74a4649b7c5908690cf60137263d8d80de5f","analyzedAt":"2026-08-15T01:48:17.006Z","schemaVersion":2},"datasetVersion":"2026-08-15T22:17:37.221Z"}