diff --git a/tests/base.py b/tests/base.py index 137d3587..e9dae5ab 100644 --- 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 index a4019ca4..d2644bd1 100644 --- 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