diff --git a/airbyte-integrations/connectors/source-mgramseva/source_mgramseva/source.py b/airbyte-integrations/connectors/source-mgramseva/source_mgramseva/source.py index 5e5637bb6b81..6f102cae1af0 100644 --- a/airbyte-integrations/connectors/source-mgramseva/source_mgramseva/source.py +++ b/airbyte-integrations/connectors/source-mgramseva/source_mgramseva/source.py @@ -349,9 +349,11 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]: end_date = datetime.today() end_date = pytz.IST.localize(end_date).astimezone(pytz.utc) + streams = [] + for tenantid in self.config["tenantids"]: # Generate streams for each object type - streams = [ + streams += [ MgramsevaPayments(self.headers, self.request_info, self.user_request, tenantid), MgramsevaTenantExpenses(self.headers, self.request_info, self.user_request, tenantid, start_date, end_date), MgramsevaDemands(self.headers, self.request_info, self.user_request, tenantid), @@ -365,4 +367,4 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]: streams.append(MgramsevaBills(self.headers, self.request_info, self.user_request, tenantid, list(consumer_codes))) - return streams + return streams