From 982931b82fccddcf6f4e84401bf40062255aaf43 Mon Sep 17 00:00:00 2001
From: BernardWez <bernard.wezeman@quantile.nl>
Date: Mon, 20 Nov 2023 14:17:07 +0100
Subject: [PATCH] Add replication to stream

---
 elx/catalog.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/elx/catalog.py b/elx/catalog.py
index d09d7ce..d4e1caa 100644
--- 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