ErrLookup › pathwaycom/pathway
pathwaycom/pathway
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG. · Python · 716 source files
Analyzed at fa2f74a464 on 2026-08-15. 420 documented errors.
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Failed to install dependencies | exception | error | pathway, kafka, configuration, validation, streaming |
| Column {pseudocolumn} has to contain integers only. | validation | error | pathway, kafka, validation, epoch, streaming |
| Column {api.TIME_PSEUDOCOLUMN} cannot contain negative times | validation | error | pathway, kafka, configuration, validation |
| Column {api.DIFF_PSEUDOCOLUMN} can only have 1 and -1 values | validation | error | pathway, deprecation, configuration, persistence |
| parameters `schema` and `id_from` are mutually exclusive | validation | error | pathway, column-reference, validation, connector |
| schema does not match given dataframe | validation | error | pathway, clickhouse, configuration, validation |
| negative timestamp cannot be used | validation | error | pathway, airbyte, configuration, validation |
| only diffs of 1 and -1 are supported | validation | error | pathway, airbyte, configuration, multi-stream |
| demo.generate_custom_stream error: nb_rows should be None or | validation | error | pathway, airbyte, deprecation, breaking-change, upgrade |
| demo.noisy_linear_stream error: nb_rows should be strictly p | validation | error | pathway, airbyte, gcp, credentials, configuration |
| demo.range_stream error: nb_rows should be strictly positive | validation | error | pathway, airbyte, configuration, validation |
| Invalid schema. Time columns must be int or float. | validation | error | pathway, airbyte, internal-invariant, runtime |
| demo.replay_csv_with_time: unit should be either 's', 'ms, ' | validation | error | pathway, airbyte, persistence, multi-stream, runtime |
| invalid ssl mode '{ssl_mode}', expected one of disable, allo | validation | error | pathway, chroma, vector-db, column-reference, validation |
| Failed to detect the region of S3 bucket {bucket!r} (HTTP st | validation | error | pathway, clickhouse, schema, reserved-names, validation |
| Incorrect S3 path: {s3_path} | validation | error | pathway, clickhouse, snapshot, primary-key, validation |
| SchemaRegistryHeader.key must be a str, got {type(self.key). | validation | error | pathway, clickhouse, configuration, primary-key, validation |
| SchemaRegistryHeader.value must be a str, got {type(self.val | validation | error | pathway, deltalake, schema, metadata, interoperability |
| SchemaRegistrySettings.urls must be a list of strings, got { | validation | error | pathway, deltalake, partitioning, column-reference, validation |
| SchemaRegistrySettings requires at least one entry in 'urls' | validation | error | pathway, deltalake, optimizer, partitioning, validation |
| SchemaRegistrySettings.urls[{i}] must be a non-empty string; | validation | error | kafka, schema-registry, validation, configuration |
| SchemaRegistrySettings.{field_name} must be a str, got {type | validation | error | kafka, schema-registry, type-error, configuration |
| SchemaRegistrySettings: 'password' was provided without 'use | validation | error | kafka, schema-registry, authentication, configuration |
| SchemaRegistrySettings: 'token_authorization' is mutually ex | validation | error | kafka, schema-registry, authentication, configuration |
| SchemaRegistrySettings.headers[{i}] must be a SchemaRegistry | validation | error | kafka, schema-registry, type-error, headers |
| SchemaRegistrySettings.timeout must be a datetime.timedelta, | validation | error | kafka, schema-registry, type-error, timeout |
| SchemaRegistrySettings: 'timeout' must be a positive duratio | validation | error | kafka, schema-registry, timeout, validation |
| Column {DIFF_PSEUDOCOLUMN} can only contain 1 and -1. | validation | error | pandas, testing, data-ingestion, validation |
| duplicated entries for key {row.key} | validation | error | data-ingestion, update-stream, primary-key, testing |
| Table.groupby() received extra kwargs. You probably want to | validation | error | groupby, reduce, api-misuse, pandas |
| Table.windowby() received extra args. It handles grouping on | validation | error | windowby, temporal, api-misuse |
| Table.windowby() received extra kwargs. You probably want to | validation | error | windowby, reduce, api-misuse, pandas |
| Received `how` argument but was not expecting any. Consider | validation | error | join, api-misuse, kwargs |
| Received `how` argument of join that is a string. You probab | validation | error | join, api-misuse, enum |
| How argument of join should be one of JoinMode.INNER, JoinMo | validation | error | join, api-misuse, enum |
| Received `id` argument but was not expecting any. Not every | validation | error | join, api-misuse, kwargs, id-column |
| Received `id` argument of join that is a string. Did you mea | validation | error | join, api-misuse, id-column, type-error |
| The id argument of a join has to be a ColumnReference. | validation | error | join, instance, api-misuse, kwargs |
| `left_instance` and `right_instance` arguments to join shoul | validation | error | join, asof-join, enum, api-misuse |
| Received `direction` argument of join that is a string. You | validation | error | join, asof-join, enum, type-error |
| direction argument of join should be of type asof_join.Direc | validation | error | pathway, join, asof-join, argument-validation, type-error |
| The behavior argument of join should be of type pathway.temp | validation | error | pathway, join, temporal, argument-validation, migration |
| The interval argument of a join should be of a type pathway. | validation | error | pathway, join, interval-join, argument-validation, type-error |
| Join received extra kwargs. You probably want to use TableLi | validation | error | pathway, join, api-misuse, argument-validation |
| Expected a ColumnReference, found a string. Did you mean thi | validation | error | pathway, reduce, argument-validation, type-error |
| In reduce() all positional arguments have to be a ColumnRefe | validation | error | pathway, reduce, argument-validation |
| In select() all positional arguments have to be a ColumnRefe | validation | error | pathway, select, argument-validation |
| Cannot flatten column of type {dtype}. | validation | error | pathway, flatten, dtype, type-error |
| wrong iteration limit | validation | error | pathway, iterate, argument-validation, configuration |
| argument {name} has incorrect schema | exception | error | pathway, schema, type-checking, argument-validation |
| Unexpected value for {name!r} environment variable: {value!r | exception | error | pathway, configuration, environment-variables, deployment |
| unexpected value of PATHWAY_SNAPSHOT_ACCESS environment vari | exception | critical | pathway, persistence, environment-variables, configuration |
| Unable to process negative update with this stateful reducer | exception | error | pathway, custom-reducers, streaming, retractions |
| The column {column} doesn't belong to the target table {tabl | exception | error | pathway, io, output, sort, argument-validation |
| synchronization_group can only be set once | exception | error | pathway, connectors, synchronization, api-misuse |
| not supported type of debug data | exception | error | pathway, debug, type-error, developer-tooling |
| DateTimeNaive cannot contain timezone information. Use pw.Da | exception | error | pathway, datetime, timezone, schema, type-error |
| DateTimeUtc must contain timezone information. Use pw.DateTi | exception | error | pathway, datetime, timezone, schema, type-error |
| Duplicate expression value given for {name} | exception | error | pathway, column-selection, duplicate-key, api-misuse |
| Can't use 'id' as a column name | exception | error | pathway, reserved-name, primary-key, column-selection |
| Unsupported type {input_type}, use pw.DATE_TIME_UTC or pw.DA | exception | error | pathway, dtype, datetime, schema, type-system |
| Unsupported type {input_type}, use pw.DURATION | exception | error | pathway, dtype, timedelta, duration, schema |
| Unsupported type {input_type!r}. | exception | error | pathway, dtype, unsupported-type, schema, type-system |
| Failed to parse DType from dict: {data} | exception | error | pathway, dtype, serialization, version-mismatch, persistence |
| Cannot use expression as boolean. | exception | error | pathway, expression, boolean-operator, api-misuse, vectorization |
| string {freq} cannot be parsed as a duration | exception | error | pathway, datetime, frequency, pandas, validation |
| unit has to be one of s, ms, us, ns but is {unit}. | exception | error | pathway, datetime, timestamp, unit-validation, api-misuse |
| If fmt is not a string, you need to specify whether objects | exception | error | pathway, datetime, strptime, timezone, validation |
| Value {val} is not of type {dtype}. | exception | error | pathway, dtype, data-quality, schema-mismatch, runtime |
| Pathway does not support using binary operator {expression._ | exception | error | pathway, binary-operator, dtype, type-mismatch, expression |
| Pathway doesn't support casting {source_type} to {target_typ | exception | error | pathway, cast, dtype, type-conversion, expression |
| Pathway doesn't support converting {source_type} to {target_ | exception | error | pathway, dtype, conversion, unwrap, expression |
| Column of type {dtypes[0]} has no attribute {expression._nam | exception | error | pathway, attribute-access, dtype, namespace, expression |
| invalid expression in restricted context | exception | error | pathway, restricted-context, column-reference, scope, join |
| wrong schema of debug data | exception | error | pathway, debug, schema-mismatch, test-fixture, datasource |
| datasource not supported | exception | error | pathway, datasource, custom-connector, internals, version-mismatch |
| datasink not supported | exception | error | pathway, datasink, custom-connector, internals, output |
| transformer has no attribute `{table_name}` | exception | error | pathway, table-transformer, attribute-error, api-misuse |
| `{self.name}` has no attribute `{name}` | exception | error | pathway, row-transformer, attribute-error, schema, api-misuse |
| column out of scope | exception | error | pathway, internals, graph-runner, scope, internal-error |
| table out of scope | exception | error | pathway, internals, graph-runner, scope, internal-error |
| path storage out of scope | exception | error | pathway, internals, graph-runner, scope, internal-error |
| You cannot use {dep.to_column_expression()} in this reduce s | exception | error | pathway, groupby, reduce, validation, api-misuse |
| You cannot use {dep.to_column_expression()} in this context. | exception | error | pathway, groupby, universe, reduce, api-misuse |
| Cannot enable interactive mode | exception | error | pathway, interactive-mode, notebook, api-misuse |
| Cannot assign id's for this join type. | exception | error | pathway, join, id-column, api-misuse |
| Expected a ColumnReference, found a string. Did you mean thi | exception | error | pathway, join, groupby, api-misuse, type-error |
| In JoinResult.groupby() all arguments have to be a ColumnRef | exception | error | pathway, join, groupby, api-misuse, type-error |
| In JoinResult.reduce() all positional arguments have to be a | exception | error | pathway, join, reduce, api-misuse, type-error |
| Cannot join table with itself. Use <table>.copy() as one of | exception | error | pathway, join, self-join, api-misuse |
| join condition should be of form <left_table>.<column> == <r | exception | error | pathway, join, condition, validation, api-misuse |
| Incompatible types in a join condition. The types are: {eval | exception | error | pathway, join, types, type-mismatch, api-misuse |
| The boolean condition is not properly ordered. The left part | exception | error | pathway, join, condition, ordering, api-misuse |
| Left part of a join condition has to be a reference to a tab | exception | error | pathway, join, condition, api-misuse |
| Right part of a join condition has to be a reference to a ta | exception | error | pathway, join, condition, api-misuse |
| Cannot convert Json {self.value} to {type} | exception | error | json, type-conversion, runtime, pathway |
| {name} has to be a Table instead of {type(arg)} | exception | error | pathway, table-transformer, iteration, type-error |
| not all arguments marked as iterated returned from iteration | exception | error | pathway, iteration, table-transformer, universe |
| output: {result_schema} of the iterated function does not c | exception | error | pathway, iteration, schema-mismatch, table-transformer |
| iterated table not marked as 'iterate_universe' changed its | exception | error | pathway, iteration, universe, table-transformer |
| Incompatible types in for a binary operator. The types are: | exception | error | pathway, dtype, pointer, binary-operator, type-mismatch |
| Pathway does not support using reducer {self} on column of t | exception | error | pathway, reducer, dtype, aggregation, type-mismatch |
| Setting strict=True in pathway.reducers.sum when the column | exception | error | pathway, reducer, sum, configuration |
| Pathway does not support using reducer {self.name} on column | exception | error | pathway, reducer, dtype, aggregation, type-mismatch |
| creating a reference to a class_arg table defined for anothe | exception | error | pathway, row-transformer, class-arg, api-misuse |
| output schema validation error, received {output.as_typehint | exception | error | pathway, row-transformer, schema-mismatch, validation |
| `{column_name}` should be a column definition, found {type(c | exception | error | pathway, schema, column-definition, type-annotation |
| type annotation of column `{column_name}` does not match col | exception | error | pathway, schema, dtype, type-annotation |
| ambiguous property; schema property `{property_name}` has va | exception | error | pathway, schema, column-properties, configuration |
| definitions of columns {names} lack type annotation | exception | error | pathway, schema, type-annotation, column-definition |
| Schemas should not be called. Use `table.schema` not `table. | exception | error | pathway, schema, api-misuse, migration |
| Schema.with_types() argument name has to be an existing colu | exception | error | pathway, schema, api-misuse, validation |
| Schema.without() argument {name!r} has to refer to an existi | exception | error | pathway, schema, api-misuse, validation |
| schema does not have columns {missing_columns} | exception | error | pathway, schema, assertion, validation, testing |
| there are extra columns: {extra_columns} which are not prese | exception | error | pathway, schema, assertion, validation, testing |
| Unknown source component: {self.source_component} | exception | error | schema, configuration, pathway |
| can't generate Schema based on an empty CSV file | exception | error | csv, schema, io, pathway |
| parsing {query} failed | exception | error | sql, validation, pathway |
| {node.sql()} not supported. | exception | error | sql, pathway, not-implemented |
| PIVOTS not supported | exception | error | sql, pivot, pathway, not-implemented |
| Correlated subqueries not supported. | exception | error | sql, subquery, pathway |
| {key}: {repr} not supported. | exception | error | sql, pathway, not-implemented |
| Table.__getitem__ argument has to be a ColumnReference to th | exception | error | column-reference, api-misuse, pathway |
| Table.from_columns() cannot have empty arguments list | exception | error | api-misuse, validation, pathway |
| Universes of all arguments of Table.from_columns() have to b | exception | error | universe, api-misuse, pathway |
| Universes of all arguments of Table.__add__() have to be equ | exception | error | universe, operator, pathway |
| Filter argument of Table.filter() has to be bool, found {fil | exception | error | type-check, filter, pathway |
| Table.restrict(): other universe has to be a subset of self | exception | error | universe, restrict, pathway |
| Table.groupby() cannot have id argument when grouping by mul | exception | error | groupby, api-misuse, pathway |
| Table.groupby() received id argument and is grouped by a sin | exception | error | groupby, api-misuse, pathway |
| Expected a ColumnReference, found a string. Did you mean <ta | exception | error | groupby, api-misuse, pathway |
| All Table.groupby() arguments have to be a ColumnReference. | exception | error | groupby, api-misuse, pathway |
| Table expected here. | exception | error | ix, context, pathway |
| Const value provided. | exception | error | ix, api-misuse, pathway |
| Pathway supports indexing with Pointer type only. The type u | exception | error | pathway, typing, table-indexing, pointer |
| Indexing a table with a Pointer type with probably mismatche | exception | error | pathway, typing, table-indexing, pointer, id-type |
| columns do not match in the argument of Table.concat(). Miss | exception | error | pathway, schema, table-concat, columns |
| Universes of the arguments of Table.concat() have to be disj | exception | error | pathway, universe, table-concat, disjoint |
| Columns of the argument in Table.update_cells() not present | exception | error | pathway, schema, update-cells, columns |
| Universe of the argument of Table.update_cells() needs to be | exception | error | pathway, universe, update-cells, subset |
| Columns do not match between argument of Table.update_rows() | exception | error | pathway, schema, update-rows, columns |
| Pathway supports reindexing Tables with Pointer type only. T | exception | error | pathway, typing, reindex, pointer |
| Column {old_name} does not exist in a given table. | exception | error | pathway, rename, columns, schema |
| Table.with_schema() argument has to have the same column nam | exception | error | pathway, schema, with-schema, columns |
| Table.update_types() argument name has to be an existing tab | exception | error | pathway, typing, update-types, columns |
| Cannot change type from {right} to {left}.\nTable.update_typ | exception | error | pathway, typing, update-types, type-cast |
| Table.cast_to_types() argument name has to be an existing ta | exception | error | pathway, typing, cast-to-types, columns |
| You cannot use {dep.to_column_expression()} in this context. | exception | error | pathway, universe, expressions, join |
| Using column of type {dtype.typehint} is not allowed here. C | exception | error | pathway, async, future, typing |
| Expected 'is_upsert' to be of type 'bool', got '{is_upsert_t | exception | error | pathway, typing, stream-to-table, bool |
| Incompatible types for {function_name} operation.\nThe types | exception | error | pathway, typing, binary-op, join |
| The field '{column_name}' in the schema of the source '{data | exception | error | pathway, datasource, schema, source-component |
| {name!r} is a method name. It is discouraged to use it as a | exception | error | pathway, column-name, table-slice, api-collision |
| Column name {name!r} not found in {self!r}. | exception | error | pathway, column-name, table-slice, attributeerror |
| Column name {repr(colname)} not found in a {self}. | exception | error | pathway, table-slice, column-not-found, keyerror |
| Column name {repr(old)} not found in a {self}. | exception | error | pathway, table-slice, rename, column-not-found |
| TableSlice expects {repr(arg.name)} or this.{arg.name} argum | exception | error | pathway, table-slice, column-reference, this |
| TableSlice method arguments should refer to table of which t | exception | error | pathway, table-slice, column-reference, wrong-table |
| {name} is a method name. It is discouraged to use it as a co | exception | error | pathway, this, column-name-clash, getattr |
| You cannot iterate over mock class. | exception | error | pathway, this, iteration, typeerror |
| You cannot instantiate `this` class. | exception | error | pathway, this, instantiation, typeerror |
| Usage of {base_this} not supported here. | exception | error | pathway, this, join, substitution, typeerror |
| Pathway does not support using unary operator {operator_fun. | exception | error | pathway, type-checking, unary-operator, dtype, typeerror |
| Pathway does not support using binary operator {operator.__n | exception | error | pathway, type-checking, binary-operator, dtype, typeerror |
| {expression!r} can only be applied to JSON columns, but colu | exception | error | pathway, type-checking, unwrap, json, typeerror |
| type of default {default_type.typehint} is not compatible wi | exception | error | pathway, type-checking, unwrap, default-value, typeerror |
| Cannot change type from {right} to {left}.\npw.`declare_type | exception | error | pathway, type-checking, declare-type, dtype, typeerror |
| Incompatible types in for a coalesce expression.\nThe types | exception | error | pathway, type-checking, coalesce, dtype, typeerror |
| Cannot perform pathway.coalesce on columns of types {[dtype. | exception | error | pathway, type-checking, coalesce, any-type, typeerror |
| First argument of pathway.if_else has to be bool, found {if_ | exception | error | pathway, type-checking, if-else, bool, typeerror |
| Cannot perform pathway.if_else on columns of types {then_dty | exception | error | pathway, type-checking, if-else, dtype, typeerror |
| Default must be of type {Json | None}, found {default_dtype. | exception | error | pathway, json, get, default-value, typeerror |
| Cannot get from {Json | None}. | exception | error | pathway, json, get, optional, typeerror |
| Object in {expression!r} has to be a JSON or sequence. | exception | error | pathway, types, json, schema |
| Index in {expression!r} has to be an int. | exception | error | pathway, types, indexing, json |
| Index n | exception | error | pathway, types, tuple, indexing |
| Index {expression._const_index} out of range for a tuple of | exception | error | pathway, types, tuple, indexing, schema |
| Column of type {dtypes[0].typehint} has no attribute {expres | exception | error | pathway, types, methods, dtype-dispatch |
| Cannot perform pathway.fill_error on columns of types {inner | exception | error | pathway, types, fill-error, error-handling |
| Cannot perform {name} when column of type {dtypes_repr} is i | exception | error | pathway, async, udf, futures, types |
| Batching is not supported for fully asynchronous UDFs. | exception | error | pathway, udf, async, batching |
| A batch UDF has to return a list but is annotated as returni | exception | error | pathway, udf, batching, type-annotation |
| The function is a coroutine. You can't use SyncExecutor. | exception | error | pathway, udf, async, executor |
| cache name `{name}` used more than once | exception | error | pathway, udf, cache, configuration |
| no persistent storage configured for the disk cache | exception | critical | pathway, udf, cache, environment, configuration |
| expected string key, got {type(key)} | exception | error | pathway, yaml, configuration, parsing |
| variable {v} is not defined | exception | error | pathway, yaml, variables, configuration |
| At least two columns must participate in a connector group | exception | error | pathway, io, synchronization, connectors |
| The 'max_difference' must either be an integer or a datetime | exception | error | pathway, io, synchronization, validation |
| The 'max_difference' can't be negative | exception | error | pathway, io, synchronization, validation |
| Failed to find the column '{column._name}' in table {column. | exception | error | pathway, io, synchronization, schema, columns |
| Only one column from a table can be used in a synchronizatio | exception | error | pathway, io, synchronization, connectors, validation |
| Only unchanged columns of an input tables can be used in inp | exception | error | |
| All synchronization group column types must coincide. Howeve | exception | error | |
| Fields of type {column_type.typehint} are not supported in c | exception | error | |
| If max_difference is an integer value, the values of a colum | exception | error | |
| If max_difference is a Duration, the values of a column must | exception | error | |
| '{param_name}' must be a number of seconds (int or float) or | exception | error | |
| '{param_name}' must be finite, got {value!r} | exception | error | |
| '{param_name}' must be {constraint}, got {value!r} | exception | error | |
| data format `{format}` not supported | exception | error | |
| Got unexpected keyword arguments: {unexpected_arg_names} | exception | error | |
| Unknown mode: {}. Only {} are supported | exception | error | |
| Schema must be specified. Consider using `pw.schema_from_csv | exception | error | |
| Schema must be specified. | exception | error | |
| Unexpected argument for {format!r} format: {param} | exception | error | |
| The schema already declares a {METADATA_COLUMN_NAME!r} colum | exception | error | |
| {METADATA_COLUMN_NAME!r} is a reserved column name used by P | exception | error | |
| Unexpected argument for csv format: json_field_paths | exception | error | |
| Unexpected argument for json format: csv_settings | exception | error | |
| 'autogenerate_key' is only meaningful for 'raw' or 'plaintex | exception | error | |
| 'json_field_paths' cannot be used for {METADATA_COLUMN_NAME! | exception | error | |
| 'json_field_paths' references field {field_name!r} which is | exception | error | pathway, connector, json, schema, validation |
| Invalid JSON Pointer for field {field_name!r}: {path!r}. JSO | exception | error | pathway, connector, json-pointer, rfc6901, validation |
| Unsupported argument for {data_format!r} format: 'value' | validation | error | pathway, kafka, message-queue, format, validation |
| 'delimiter' is only meaningful for the 'dsv' format, but {fo | validation | error | pathway, kafka, output, dsv, delimiter, validation |
| 'subject' was provided without 'schema_registry_settings'. T | validation | error | pathway, kafka, schema-registry, output, validation |
| 'schema_registry_settings' was provided without 'subject'. W | validation | error | pathway, kafka, schema-registry, output, validation |
| 'subject' must be a non-empty string; got an empty string. S | validation | error | pathway, kafka, schema-registry, configuration, validation |
| 'schema_registry_settings' is only meaningful for the 'json' | validation | error | pathway, kafka, schema-registry, format, validation |
| The topic name column must have a string type, however {topi | validation | error | pathway, kafka, dtype, topic-routing, validation |
| The key column must have one of the following types: {allowe | validation | error | pathway, kafka, dtype, key, validation |
| {header.name!r} is reserved for the Pathway-injected headers | validation | error | pathway, kafka, headers, reserved-names, validation |
| Duplicate header name {header.name!r}: two columns produce a | validation | error | pathway, kafka, headers, duplicate, validation |
| 'value' and format='{format}' cannot be set at the same time | validation | error | pathway, kafka, format, value-column, validation |
| The table has columns {sorted(conflicting)} which clash with | validation | error | pathway, kafka, json, reserved-names, validation |
| 'value' must be specified if 'key' is not None | validation | error | pathway, kafka, raw, key-value, validation |
| '{format}' format without explicit 'value' specification can | validation | error | pathway, kafka, raw, single-column, validation |
| The value column must have one of the following types: {allo | validation | error | pathway, kafka, dtype, raw, validation |
| Unsupported format: {format} | validation | error | pathway, kafka, output, format, validation |
| Two different columns share the output name {column_name!r}. | validation | error | pathway, kafka, column-names, collision, validation |
| start_from_timestamp_ms is required when start_from='timesta | validation | error | |
| start_from_timestamp_ms must be a non-negative number of mil | validation | error | |
| start_from_timestamp_ms must not be set when start_from='{st | validation | error | |
| 'persistent_id' and 'name' should not be used together. Plea | validation | error | |
| The column {column} doesn't belong to the target table | validation | error | |
| Invalid init_mode: {init_mode} | validation | error | |
| Stream {name} has unknown sync_mode: {sync_mode} | validation | error | |
| All streams within the same 'pw.io.airbyte.read' must have t | validation | error | |
| `refresh_interval_ms` was replaced by `refresh_interval`, wh | validation | error | |
| 'service_user_credentials_file' is required for the 'remote' | validation | error | |
| Unknown execution type: {execution_type}. Only 'local' and ' | validation | error | |
| Unknown sync_mode: {self.sync_mode} | exception | error | |
| Persistence in airbyte connector is supported only for the c | exception | error | |
| {role} column {column._name!r} does not belong to the provid | validation | error | |
| Column name(s) {sorted(reserved)!r} collide with the reserve | validation | error | |
| output_table_type='snapshot' requires the primary_key parame | validation | error | |
| The primary_key parameter is only used with output_table_typ | validation | error | |
| No Pathway table schema is stored in the given Delta table's | validation | error | |
| The suggested partition column {column} doesn't belong to th | validation | error | |
| Optimization is based on the column '{table_optimizer.tracke | validation | error | |
| database {path_str!r} is an existing directory, not a DuckDB | validation | error | duckdb, filesystem, connector, config |
| primary_key can only be specified for the snapshot table typ | validation | error | duckdb, connector, api-misuse |
| primary_key must be specified for the snapshot table type | validation | error | duckdb, connector, api-misuse |
| sort_by cannot be used with the snapshot table type: a snaps | validation | error | duckdb, connector, data-loss, ordering |
| detach_between_batches=True cannot be used with database=":m | validation | error | duckdb, connector, in-memory, data-loss |
| pw.Schema has column names that differ only in case ({case_c | validation | error | duckdb, schema, case-sensitivity, connector |
| Column(s) {collisions} collide with the 'time' and 'diff' me | validation | error | duckdb, schema, reserved-names, connector |
| primary_key contains duplicate column(s) {sorted(duplicates) | validation | error | duckdb, primary-key, connector, api-misuse |
| primary_key column {pkey.name!r} is declared nullable ({pkey | validation | error | duckdb, primary-key, schema, nullable |
| primary_key column {pkey.name!r} has non-scalar type ({pkey. | validation | error | duckdb, primary-key, schema, type-mismatch |
| timestamp_column {timestamp_column!r} is not present in the | validation | error | elasticsearch, schema, connector, api-misuse |
| id_column {id_column!r} is not present in the schema | validation | error | elasticsearch, schema, connector, api-misuse |
| Defining a primary key in the schema is not supported for pw | validation | error | elasticsearch, schema, primary-key, connector |
| read_batch_size must be positive | validation | error | elasticsearch, validation, config, connector |
| Unknown format: {}. Only {} are supported | validation | error | filesystem, format, connector, api-misuse |
| Unknown list objects strategy: {self.list_objects_strategy} | validation | error | gdrive, enum, connector, internal-api |
| Unrecognized connector mode: {mode} | validation | error | gdrive, connector, api-misuse, validation |
| Unknown payload format: {req_format} | validation | error | http, format, internal-api, connector |
| Duplicate example id: {id} | validation | error | http, openapi, examples, api-misuse |
| Unknown endpoint input format: {format} | validation | error | http, openapi, format, internal-api |
| 'raw' endpoint input format requires 'value' column in schem | validation | error | http, rest-connector, schema, pathway |
| If webserver object isn't specified, host and port must be p | validation | error | http, rest-connector, configuration, pathway |
| If webserver object is specified, host and port shouldn't be | validation | error | http, rest-connector, configuration, api-misuse, pathway |
| Iceberg reader requires explicit primary key fields specific | validation | error | iceberg, schema, primary-key, pathway |
| rdkafka_settings must contain a non-empty 'bootstrap.servers | validation | error | kafka, configuration, connection, pathway |
| rdkafka_settings must contain a non-empty 'group.id' entry: | validation | error | kafka, configuration, consumer-group, pathway |
| 'max_backlog_size' must be positive; got {max_backlog_size}. | validation | error | kafka, validation, backpressure, pathway |
| 'parallel_readers' must be positive; got {parallel_readers}. | validation | error | kafka, validation, parallelism, pathway |
| 'start_from_timestamp_ms' must be non-negative; got {start_f | validation | error | kafka, validation, timestamp, pathway |
| 'autocommit_duration_ms' must be positive; got {autocommit_d | validation | error | kafka, validation, offsets, pathway |
| Got unexpected keyword argument 'topic_name'. pw.io.kafka.re | validation | error | kafka, api-misuse, typo, pathway |
| Missing topic name specification | validation | error | kafka, api-misuse, configuration, pathway |
| 'topic_names' must be a str or a list of str; got {type(topi | validation | error | kafka, api-misuse, deprecated, pathway |
| 'topic' must be a non-empty string; got an empty list. Kafka | validation | error | kafka, api-misuse, validation, pathway |
| 'topic' must be a non-empty string; got {topic!r}. Kafka doe | validation | error | kafka, validation, configuration, pathway |
| 'simple_read' does not accept {forbidden!r}. If you need to | validation | error | kafka, api-misuse, configuration, pathway |
| 'read_only_new=True' together with mode='static' is self-con | validation | error | kafka, api-misuse, mode-conflict, pathway |
| 'read_only_new=True' and 'start_from_timestamp_ms' both cont | validation | error | kafka, api-misuse, offsets, pathway |
| rdkafka_settings must contain a non-empty 'bootstrap.servers | validation | error | kafka, configuration, connection, pathway |
| 'topic_name' must be a non-empty string; got an empty string | validation | error | kafka, validation, configuration, pathway |
| The sort_by column {column} doesn't belong to the table pass | validation | error | kafka, pathway, sort, column-reference, validation |
| The sort_by column {column.name!r} is not part of the data b | validation | error | kafka, pathway, sort, format, validation |
| LEANN connector requires the `leann` package. Please visit h | exception | error | leann, pathway, import, optional-dependency, installation |
| {role} {col._name!r} must be of type str, got {col._column.d | validation | error | leann, pathway, dtype, type-mismatch, validation |
| text_column {text_column._name!r} does not belong to the pro | validation | error | leann, pathway, column-reference, validation |
| metadata column {col._name!r} does not belong to the provide | validation | error | leann, pathway, column-reference, metadata, validation |
| Column {k!r} contains a {v.ndim}-dimensional numpy array. pw | validation | error | milvus, pathway, numpy, embeddings, validation |
| Column {k!r} contains a value of unsupported type {type(v)._ | validation | error | milvus, pathway, type-mismatch, serialization, validation |
| Column {k!r} contains a non-finite value (NaN or infinity) i | validation | error | milvus, pathway, nan, embeddings, data-quality |
| milvus-lite failed to start a local server for: {uri} | exception | error | milvus, milvus-lite, runtime, embedded-server, environment |
| batch_size must be a positive integer, got {batch_size}. | validation | error | milvus, pathway, configuration, validation |
| primary_key column {primary_key._name!r} does not belong to | validation | error | milvus, pathway, column-reference, primary-key, validation |
| Milvus collection {collection_name!r} does not exist; create | validation | error | milvus, pathway, collection, schema, setup |
| Defining a primary key in the schema is not supported for pw | validation | error | mongodb, pathway, schema, primary-key, validation |
| Column name '_id' is reserved: MongoDB uses '_id' as the pri | validation | error | mongodb, pathway, reserved-name, schema, validation |
| Column name(s) {sorted(reserved)!r} collide with the reserve | validation | error | mongodb, pathway, reserved-name, change-data-capture, validation |
| The MQTT topic to read from must not be empty. | validation | error | mqtt, pathway, configuration, topic, validation |
| The MQTT topic to publish to must not be empty. | validation | error | mqtt, pathway, configuration, topic, validation |
| The MQTT topic to publish to must not contain the wildcard c | validation | error | mqtt, pathway, topic, wildcard, validation |
| {arg_name} must not be empty | validation | error | mssql, validation, identifier, sql-server, pathway |
| {arg_name} must not contain NUL characters | validation | error | mssql, validation, nul-byte, encoding, pathway |
| pw.io.mssql.read requires at least one primary key column in | validation | error | mssql, primary-key, schema, cdc, pathway |
| pw.io.mssql.read primary_key column(s) {nullable_pks} are de | validation | error | mssql, primary-key, nullable, schema, cdc, pathway |
| primary_key can only be specified for the snapshot table typ | validation | error | mssql, primary-key, output-mode, sink, pathway |
| pw.Schema has column names that differ only in case ({case_c | validation | error | mssql, sql-server, case-insensitive, schema, sink, pathway |
| Column(s) {collisions} collide with the 'time' and 'diff' me | validation | error | mssql, reserved-columns, stream-mode, sink, pathway |
| primary_key contains duplicate column(s) {sorted(duplicates) | validation | error | mssql, primary-key, duplicate, snapshot, sink, pathway |
| primary_key column {pkey.name!r} is declared nullable ({pkey | validation | error | mssql, primary-key, nullable, snapshot, merge, pathway |
| pw.io.mysql.read requires at least one primary key column in | validation | error | mysql, primary-key, schema, cdc, pathway |
| pw.io.mysql.read primary_key column(s) {nullable_pks} are de | validation | error | mysql, primary-key, nullable, schema, pathway |
| Pathway schema column(s) {offending} collide with the 'time' | validation | error | mysql, reserved-columns, stream-mode, sink, pathway |
| Durable consumer name can only be used if JetStream is enabl | validation | error | nats, jetstream, durable-consumer, configuration, pathway |
| primary_key column {name!r} is nullable (type {dtype}); a Pi | validation | error | pinecone, primary-key, nullable, vector-db, pathway |
| primary_key column {name!r} has unsupported type {dtype}; a | validation | error | pinecone, primary-key, dtype, vector-db, pathway |
| vector column {name!r} is nullable (type {dtype}); every row | validation | error | pinecone, vector, nullable, embeddings, pathway |
| vector column {name!r} has type {dtype}, which is a multivec | validation | error | pinecone, multivector, vector, dtype, pathway |
| vector column {name!r} has unsupported type {dtype}; a Pinec | validation | error | pinecone, vector, dtype, embeddings, pathway |
| metadata column {name!r} has unsupported type {dtype}; Pinec | validation | error | pinecone, metadata, dtype, vector-db, pathway |
| primary_key column {primary_key._name!r} does not belong to | validation | error | pinecone, column-reference, table-identity, api-misuse, pathway |
| vector column {vector._name!r} does not belong to the provid | validation | error | pinecone, pathway, column-reference, api-misuse |
| primary_key and vector both reference column {pk_name!r}; th | exception | error | pinecone, pathway, duplicate-argument, validation |
| metadata column {col._name!r} does not belong to the provide | exception | error | pinecone, pathway, column-reference, metadata |
| column {col._name!r} is used as the {role} and cannot also b | exception | error | pinecone, pathway, duplicate-argument, metadata |
| batch_size must be a positive integer, got {batch_size}. | exception | error | pinecone, pathway, invalid-argument, batching |
| A Pinecone API key is required. Pass api_key=... or set the | exception | error | pinecone, pathway, credentials, environment |
| sslrootcert doesn't point to a file | exception | error | postgres, tls, ssl, configuration |
| sslrootcert points to a non-existent path | exception | error | postgres, tls, ssl, file-not-found, configuration |
| sslrootcert is not readable: {e} | exception | error | postgres, tls, ssl, permissions, configuration |
| 'publication_name' is not needed for the static mode | exception | error | postgres, cdc, replication, invalid-argument |
| 'replication_slot_name' is not needed for the static mode | exception | error | postgres, cdc, replication, invalid-argument |
| 'snapshot_name' is not needed for the static mode | exception | error | postgres, cdc, replication, invalid-argument |
| 'publication_name' is required for the streaming mode | exception | error | postgres, cdc, replication, missing-argument |
| Either none or both of 'replication_slot_name', 'snapshot_na | exception | error | postgres, cdc, replication, argument-pairing |
| Pathway schema column(s) {offending} collide with the 'time' | exception | error | postgres, pathway, schema, naming-collision, ddl |
| _external_diff_column is only supported for the snapshot tab | exception | error | postgres, pathway, snapshot, api-misuse |
| primary_key can only be specified for the snapshot table typ | exception | error | postgres, pathway, snapshot, primary-key, api-misuse |
| primary key field names must be specified for a snapshot mod | exception | error | postgres, pathway, snapshot, primary-key, validation |
| _external_diff_column can only have an integer type | exception | error | postgres, pathway, dtype, snapshot, validation |
| primary_key references column(s) {foreign} that are not pres | exception | error | postgres, pathway, snapshot, primary-key, column-reference |
| primary_key contains duplicate column(s) {duplicates} | exception | error | pathway, postgres, primary-key, validation |
| primary_key column '{pkey_field.name}' is declared nullable; | exception | error | pathway, postgres, primary-key, nullable, snapshot |
| Pathway schema column(s) {offending} collide with the 'time' | exception | error | pathway, postgres, deprecated, column-collision, snapshot |
| Unexpected number of columns: {len(row)} | exception | error | pathway, gcp, pubsub, runtime, schema |
| Unexpected value type. Expected bytes, got {type(data)} | exception | error | pathway, gcp, pubsub, type-mismatch, bytes, runtime |
| Unexpected number of columns in table: {len(table._columns)} | exception | error | pathway, gcp, pubsub, schema, validation |
| The column should be of the type 'bytes' | exception | error | pathway, gcp, pubsub, type-mismatch, bytes |
| Mutual TLS (client certificate) authentication is not suppor | exception | error | pathway, pulsar, tls, authentication, unsupported |
| Topic name must not be empty | exception | error | pathway, pulsar, topic, configuration, env |
| Trying to modify a row in {type(self)} but deletions_enabled | exception | error | pathway, python-connector, upsert, runtime, api-misuse |
| Trying to delete a row in {type(self)} but deletions_enabled | exception | error | pathway, python-connector, deletions, runtime, api-misuse |
| You can't use the same ConnectorSubject object in more than | exception | error | pathway, python-connector, api-misuse, shared-state |
| batch_size must be a positive integer, got {batch_size}. | exception | error | pathway, qdrant, vector-db, configuration, validation |
| designated_timestamp is passed, but designated_timestamp_pol | exception | error | pathway, questdb, configuration, timestamp, conflicting-args |
| the designated_timestamp column {designated_timestamp.name!r | exception | error | pathway, questdb, type-mismatch, timestamp, datetime |
| designated_timestamp_policy="use_column" requires the design | exception | error | pathway, questdb, configuration, timestamp, missing-argument |
| path {path_str!r} is an existing directory, not a SQLite dat | exception | error | pathway, sqlite, filesystem, path, configuration |
| primary_key can only be specified for the snapshot table typ | exception | error | pathway, sqlite, output-connector, configuration |
| primary_key must be specified for the snapshot table type | exception | error | pathway, sqlite, output-connector, configuration |
| pw.Schema has column names that differ only in case ({case_c | exception | error | pathway, sqlite, schema, case-sensitivity |
| Column(s) {collisions} collide with the 'time' and 'diff' me | exception | error | pathway, sqlite, schema, naming-conflict |
| primary_key contains duplicate column(s) {sorted(duplicates) | exception | error | pathway, sqlite, primary-key, validation |
| primary_key column {pkey.name!r} is declared nullable ({pkey | exception | error | pathway, sqlite, primary-key, nullable, data-integrity |
| primary_key column {primary_key._name!r} does not belong to | exception | error | pathway, weaviate, vector-store, column-reference |
| vector column {vector._name!r} does not belong to the provid | exception | error | pathway, weaviate, vector-store, column-reference, embeddings |
| Column(s) {reserved_property_columns!r} use a name reserved | exception | error | pathway, weaviate, vector-store, naming-conflict |
| {e}. Consider installing 'pathway[{extra}]' | exception | error | pathway, dependencies, installation, import-error |
| Currently, tantivy bm25 index is supported only in the as-of | exception | error | pathway, bm25, full-text-search, not-implemented, api-limitation |
| HybridIndex requires at least two indices to be provided dur | exception | error | pathway, hybrid-index, rag, validation |
| HybridIndexFactory requires at least two retriever factories | exception | error | pathway, hybrid-index, rag, factory, validation |
| Currently, usearch knn index is supported only in the as-of- | exception | error | pathway, usearch, knn, vector-search, not-implemented |
| Currently, brute force knn index is supported only in the as | exception | error | pathway, knn, brute-force, vector-search, not-implemented |
| Embedder is not a valid `pw.UDF`. | exception | error | pathway, knn, embedder, udf, type-error |
| Either `dimensions` or `embedder` must be provided to index | exception | error | pathway, knn, configuration, embeddings |
| Some columns have types incompatible with expected types: {j | exception | error | pathway, type-check, indexing, dtype |
| Not supported `type` {type} in knn_lsh_classifier_train. The | exception | error | pathway, ml, classifier, lsh, invalid-argument |
| statistical.diff(): Invalid column reference for the paramet | exception | error | pathway, statistical, diff, column-reference, api-misuse |
| statistical.diff(): Invalid column reference for the paramet | exception | error | |
| statistical.diff(): Invalid column reference for the paramet | exception | error | |
| statistical.diff(): Invalid column reference for the paramet | exception | error | |
| interpolate: Invalid mode. Only Interpolate.LINEAR is curren | exception | error | |
| Table.interpolate(): Invalid column reference for the parame | exception | error | |
| Table.interpolate(): Invalid column reference for the parame | exception | error | |
| Table.interpolate(): Invalid column reference for the parame | exception | error | |
| Table.interpolate(): Invalid column reference for the parame | exception | error | |
| Unsupported direction: {self._direction} | exception | error | |
| Unsupported asof join mode: {self._mode} | exception | error | |
| asof_now_join can only use modes pathway.JoinMode.INNER or p | exception | error | |
| Cannot join table with itself. Use <table>.copy() as one of | exception | error | |
| lower_bound has to be less than or equal to the upper_bound | exception | error | |
| behavior {behavior} unsupported in sliding/tumbling window | exception | error | |
| window_join doesn't support windows of type intervals_over | exception | error | |
| At least one of the parameters [predicate, max_gap] should b | exception | error | |
| Cannot provide both [predicate, max_gap] at the same time. | exception | error | |
| At least one of the parameters [duration, ratio] should be p | exception | error | |
| Cannot provide both [duration, ratio] at the same time. | exception | error | |
| unsupported interval type | exception | error | |
| Type has to be either TimeEventType or IntervalType. | validation | error | pathway, temporal, type-check, argument-validation |
| Arguments ({', '.join(parameters.keys())}) have to be of typ | validation | error | pathway, temporal, dtype-mismatch, argument-validation |
| result of async function does not match output schema | validation | error | pathway, async, async-transformer, schema-mismatch |
| You can't use a column of type {instance_dtype} as instance | validation | error | pathway, async, async-transformer, hashability, json |
| Input table has a column {column!r} but it is not present on | validation | error | pathway, async, async-transformer, schema-mismatch, argument-validation |
| Column {arg_name!r} is present on the argument list of the i | validation | error | pathway, async, async-transformer, schema-mismatch, argument-validation |
| exactly one of the parameters `schema` or `unpacked_columns` | validation | error | pathway, unpack, argument-validation |
| Unsupported conversion from pw.Json to {typehints[name]} | validation | error | pathway, json, type-conversion, schema |
| wrong output universe. No argument of name: {arg} | validation | error | pathway, pandas, udf, argument-validation |
| wrong output universe. Index out of range | validation | error | pathway, pandas, udf, argument-validation, index-error |
| resulting universe does not match the universe of the indica | validation | error | pathway, pandas, udf, universe, index-mismatch |
| index of resulting DataFrame must be unique | validation | error | pathway, pandas, udf, universe, duplicate-index |
| Cannot plot diff table in a static mode | exception | warning | pathway, visualization, not-implemented, static-export |