pathwaycom/pathway · error · TypeError

`refresh_interval_ms` was replaced by `refresh_interval`, wh

Error message

`refresh_interval_ms` was replaced by `refresh_interval`, which takes seconds or a timedelta. {suggestion}

What it means

Error "`refresh_interval_ms` was replaced by `refresh_interval`, which takes seconds or a timedelta. {suggestion}" thrown in pathwaycom/pathway.

Source

Thrown at python/pathway/io/airbyte/__init__.py:353

    bigger bill.
    """
    if "refresh_interval_ms" in kwargs:
        passed = kwargs["refresh_interval_ms"]
        if (
            isinstance(passed, (int, float))
            and not isinstance(passed, bool)
            and math.isfinite(passed)
        ):
            seconds = passed / 1000
            if seconds == int(seconds):
                seconds = int(seconds)
            suggestion = (
                f"Use refresh_interval={seconds} (or timedelta(seconds={seconds})) "
                f"instead of refresh_interval_ms={passed}."
            )
        else:
            suggestion = "Use refresh_interval=<seconds> (or a timedelta) instead."
        raise TypeError(
            "`refresh_interval_ms` was replaced by `refresh_interval`, which takes "
            "seconds or a timedelta. " + suggestion
        )
    refresh_interval_seconds = as_duration_seconds(refresh_interval, "refresh_interval")

    with optional_imports("airbyte"):
        from google.oauth2.service_account import Credentials as ServiceCredentials

        from pathway.io.airbyte.logic import _PathwayAirbyteSubject
        from pathway.third_party.airbyte_serverless.sources import RemoteAirbyteSource

    with open(config_file_path, "r") as f:
        yaml_config = f.read()

    source: AbstractAirbyteSource
    config = yaml.safe_load(yaml_config)
    source_config = config["source"]
    source_config["streams"] = streams

View on GitHub (pinned to fa2f74a464)

Solutions

  1. Rename refresh_interval_ms to refresh_interval and pass seconds (int/float) or a datetime.timedelta instead of milliseconds.

Example fix

pw.io.airbyte.read(..., refresh_interval=datetime.timedelta(milliseconds=old_value_ms))

When it happens

Trigger: Thrown at python/pathway/io/airbyte/__init__.py:353 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/ee6b24cb9d57d3b4. Report an issue: GitHub.