{"record":{"id":"72e37cf976a2c665","repo":"pathwaycom/pathway","slug":"persistence-in-airbyte-connector-is-supported-only","errorCode":null,"errorMessage":"Persistence in airbyte connector is supported only for the case of a single stream. Please use several airbyte connectors with one stream per connector to persist the state.","messagePattern":"Persistence in airbyte connector is supported only for the case of a single stream\\. Please use several airbyte connectors with one stream per connector to persist the state\\.","errorType":"exception","errorClass":"RuntimeError","httpStatus":null,"severity":"error","filePath":"python/pathway/io/airbyte/logic.py","lineNumber":231,"sourceCode":"\n            time_elapsed = time.time() - time_before_start\n            if time_elapsed < self.refresh_interval:\n                time.sleep(self.refresh_interval - time_elapsed)\n\n    def on_stop(self):\n        self.source.on_stop()\n\n    def _sync_mode(self):\n        stream = self.source.configured_catalog[\"streams\"][0]\n        sync_mode = stream[\"sync_mode\"]\n        return sync_mode\n\n    def _seek(self, state):\n        self.destination.set_state(json.loads(state.decode(\"utf-8\")))\n\n    def on_persisted_run(self):\n        if len(self.streams) != 1:\n            raise RuntimeError(\n                \"Persistence in airbyte connector is supported only for the case of a single stream. \"\n                \"Please use several airbyte connectors with one stream per connector to persist the state.\"\n            )\n","sourceCodeStart":213,"sourceCodeEnd":235,"githubUrl":"https://github.com/pathwaycom/pathway/blob/fa2f74a4649b7c5908690cf60137263d8d80de5f/python/pathway/io/airbyte/logic.py#L213-L235","documentation":"Error \"Persistence in airbyte connector is supported only for the case of a single stream. Please use several airbyte connectors with one stream per connector to persist the state.\" thrown in pathwaycom/pathway.","triggerScenarios":"Thrown at python/pathway/io/airbyte/logic.py:231 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Read only one stream per pw.io.airbyte.read call when using persistence; create a separate connector per stream otherwise."],"exampleFix":"pw.io.airbyte.read(config_with_single_stream, persistent_id='s1')","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-15T17:31:12.345Z"}