diff --git a/airbyte-integrations/connectors/source-mgramseva/source_mgramseva/source.py b/airbyte-integrations/connectors/source-mgramseva/source_mgramseva/source.py index e3fca2dfe2ed..78377f6dc71e 100644 --- a/airbyte-integrations/connectors/source-mgramseva/source_mgramseva/source.py +++ b/airbyte-integrations/connectors/source-mgramseva/source_mgramseva/source.py @@ -294,7 +294,7 @@ def read_records( for tenantid in self.tenantid_list: for consumer_code in self.consumer_codes[tenantid]: params = {"tenantId": tenantid, "businessService": "WS", "consumerCodes": consumer_code} - self.logger.info("requesting payments for %s", consumer_code) + # self.logger.info("requesting payments for %s", consumer_code) paymentstream = MgramsevaStream( "collection-services/payments/WS/_search", self.headers, self.request_info, self.user_request, params, "Payments" ) @@ -429,7 +429,7 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]: MgramsevaDemands(self.headers, self.request_info, self.user_request, self.config["tenantids"]), ] - # and now we need bills for each consumer + # bills and payments require a list of consumer codes for each tenant tenantid_to_consumer_codes = {} for tenantid in self.config["tenantids"]: tenantid_to_consumer_codes[tenantid] = set()