adjust_report_etl/connector.py [169:186]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        response = requests.get(ADJUST_API_URL, headers=headers, params=params)

        log.info(f"Received response with status code: {response.status_code}")
        response.raise_for_status()
    except requests.exceptions.HTTPError as err:
        log.severe(f"HTTP error occurred: {err}")
        log.severe(f"Response content: {response.text}")
    except Exception as err:
        log.severe(f"Other error occurred: {err}")

    try:
        log.info("Processing Adjust data...")
        csv_reader = csv.DictReader(StringIO(response.text))
        report_data = [row for row in csv_reader]

        log.info("Upserting rows to bigquery...")
        for row in report_data:
            yield op.upsert(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



adjust_report_etl/connector.py [239:256]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        response = requests.get(ADJUST_API_URL, headers=headers, params=params)

        log.info(f"Received response with status code: {response.status_code}")
        response.raise_for_status()
    except requests.exceptions.HTTPError as err:
        log.severe(f"HTTP error occurred: {err}")
        log.severe(f"Response content: {response.text}")
    except Exception as err:
        log.severe(f"Other error occurred: {err}")

    try:
        log.info("Processing Adjust data...")
        csv_reader = csv.DictReader(StringIO(response.text))
        report_data = [row for row in csv_reader]

        log.info("Upserting rows to bigquery...")
        for row in report_data:
            yield op.upsert(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -