Add replication to stream

quantile-development · Nov 20, 2023 · 982931b · 982931b
1 parent 1010207
commit 982931b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/elx/catalog.py b/elx/catalog.py
@@ -7,6 +7,7 @@ class Stream(BaseModel):
     stream: str = Field(alias="tap_stream_id")
     table_name: Optional[str] = None
     replication_method: Optional[str] = "FULL_TABLE"
+    replication_key: Optional[str] = None
     key_properties: List[str]
     stream_schema: dict = Field(alias="schema")
     is_view: Optional[bool] = False