Add newly discovered streams to the metadata

singer-io · Oct 16, 2023 · bd54d5d · bd54d5d
1 parent 5ae6b93
commit bd54d5d
Show file tree

Hide file tree

Showing 2 changed files with 42 additions and 3 deletions.
diff --git a/tests/base.py b/tests/base.py
@@ -855,6 +855,26 @@ def expected_metadata(self):
             'WorkStepTemplateFeed': default,
             'WorkStepTemplateHistory': incremental_created_date,
             'WorkStepTemplateShare': incremental_last_modified,
+            #added on 10/14/2023
+            'BuyerGroup': default,
+            'BuyerGroupFeed': default,
+            'BuyerGroupHistory': incremental_created_date,
+            'BuyerGroupShare': incremental_last_modified,
+            'CartDeliveryGroupMethod': default,
+            'ProductCatalog': default,
+            'ProductCatalogFeed': default,
+            'ProductCatalogHistory': incremental_created_date,
+            'ProductCatalogShare': incremental_last_modified,
+            'ProductCategory': default,
+            'ProductCategoryFeed': default,
+            'ProductCategoryHistory': incremental_created_date,
+            'ProductCategoryProduct': default,
+            'ProductCategoryProductHistory': incremental_created_date,
+            'PromotionSegmentBuyerGroup': default,
+            'PromotionSegmentBuyerGroupHistory': incremental_created_date,
+            'WebStoreBuyerGroup': default,
+            'WebStoreCatalog': default,
+            'WebStoreCatalogHistory': incremental_created_date,
         }
 
     def rest_only_streams(self):

diff --git a/tests/sfbase.py b/tests/sfbase.py
@@ -845,7 +845,27 @@ def expected_metadata():
             'WorkStepTemplateFeed': default,
             'WorkStepTemplateHistory': incremental_created_date,
             'WorkStepTemplateShare': incremental_last_modified,
-        }
+            #added on 10/14/2023
+            'BuyerGroup': default,
+            'BuyerGroupFeed': default,
+            'BuyerGroupHistory': incremental_created_date,
+            'BuyerGroupShare': incremental_last_modified,
+            'CartDeliveryGroupMethod': default,
+            'ProductCatalog': default,
+            'ProductCatalogFeed': default,
+            'ProductCatalogHistory': incremental_created_date,
+            'ProductCatalogShare': incremental_last_modified,
+            'ProductCategory': default,
+            'ProductCategoryFeed': default,
+            'ProductCategoryHistory': incremental_created_date,
+            'ProductCategoryProduct': default,
+            'ProductCategoryProductHistory': incremental_created_date,
+            'PromotionSegmentBuyerGroup': default,
+            'PromotionSegmentBuyerGroupHistory': incremental_created_date,
+            'WebStoreBuyerGroup': default,
+            'WebStoreCatalog': default,
+            'WebStoreCatalogHistory': incremental_created_date,
+             }
 
 
     @staticmethod
@@ -865,10 +885,9 @@ def rest_only_streams():
             'UndecidedEventRelation',
         }
 
-    def expected_streams(self):
+    def expected_stream_names(self):
         """A set of expected stream names"""
         streams = set(self.expected_metadata().keys())
-
         if self.salesforce_api == 'BULK':
             return streams.difference(self.rest_only_streams())
         return streams