pathwaycom/pathway · error · RuntimeError
Unknown sync_mode: {self.sync_mode}
Error message
Unknown sync_mode: {self.sync_mode} What it means
Error "Unknown sync_mode: {self.sync_mode}" thrown in pathwaycom/pathway.
Source
Thrown at python/pathway/io/airbyte/logic.py:170
self.streams = streams
self.sync_mode = self._sync_mode()
self._cache: dict[api.Pointer, bytes] = {}
self._present_keys: set[api.Pointer] = set()
def on_event(self, payload):
if self.sync_mode == INCREMENTAL_SYNC_MODE:
self.next_json({"data": payload})
elif self.sync_mode == FULL_REFRESH_SYNC_MODE:
message = json.dumps(
{"data": payload}, ensure_ascii=False, sort_keys=True
).encode("utf-8")
key = api.ref_scalar(message)
if self._cache.get(key) != message:
self._cache[key] = message
self._add(key, message)
self._present_keys.add(key)
else:
raise RuntimeError(f"Unknown sync_mode: {self.sync_mode}")
def on_state(self, state):
self._report_offset(json.dumps(state).encode("utf-8"))
self._enable_commits() # A commit is done here
self._disable_commits() # Disable commits till the next state
def run(self):
self._disable_commits()
n_times_failed = 0
while True:
time_before_start = time.time()
try:
messages = self.source.extract([self.destination.get_state()])
except Exception:
logging.exception(
"Failed to query airbyte-serverless source, retrying..."
)
n_times_failed += 1View on GitHub (pinned to fa2f74a464)
Solutions
- Use a supported sync_mode value ('full_refresh' or 'incremental').
Example fix
stream.sync_mode = 'incremental'
When it happens
Trigger: Thrown at python/pathway/io/airbyte/logic.py:170 when the library encounters an invalid state.
Common situations: See trigger scenarios.
AI-assisted analysis of pathwaycom/pathway@fa2f74a464 (2026-08-15).
Data as JSON: /api/errors/8cb6bc15dab33956.
Report an issue: GitHub.