Skip to content

Commit

Permalink
.
Browse files Browse the repository at this point in the history
  • Loading branch information
tobiascadee committed Aug 21, 2024
1 parent b6a5de4 commit ac003a9
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions tap_postgres/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,13 +14,12 @@
from typing import TYPE_CHECKING, Any, Iterable, Mapping

import psycopg2
from singer_sdk._singerlib import CatalogEntry
import singer_sdk.helpers._typing
import sqlalchemy as sa
from psycopg2 import extras
from singer_sdk import SQLConnector, SQLStream
from singer_sdk._singerlib import CatalogEntry, MetadataMapping, Schema
from singer_sdk import typing as th
from singer_sdk._singerlib import CatalogEntry, MetadataMapping, Schema
from singer_sdk.helpers._state import increment_state
from singer_sdk.helpers._typing import TypeConformanceLevel
from singer_sdk.streams.core import REPLICATION_INCREMENTAL
Expand Down Expand Up @@ -258,14 +257,14 @@ def get_schema_names(self, engine: Engine, inspected: Inspector) -> list[str]:
if "filter_schemas" in self.config and len(self.config["filter_schemas"]) != 0:
return self.config["filter_schemas"]
return super().get_schema_names(engine, inspected)

def discover_catalog_entry(
self,
engine: Engine, # noqa: ARG002
engine: Engine,
inspected: Inspector,
schema_name: str,
table_name: str,
is_view: bool, # noqa: FBT001
is_view: bool,
) -> CatalogEntry:
"""Create `CatalogEntry` object for the given table or a view.
Expand Down

0 comments on commit ac003a9

Please sign in to comment.