Hello,

Recently I started to work with Flask and have had no problems until today. I tried to run my program through Pycharm and now I keep getting the following error message:

Traceback (most recent call last):
  File "C:\Users\81704\PycharmProjects\flask-secrets\main.py", line 1, in <module>
    from flask import Flask, render_template
  File "C:\Users\81704\PycharmProjects\password-manager-start\venv\lib\site-packages\flask\__init__.py", line 4, in <module>
    from . import json as json
  File "C:\Users\81704\PycharmProjects\password-manager-start\venv\lib\site-packages\flask\json\__init__.py", line 8, in <module>
    from ..globals import current_app
  File "C:\Users\81704\PycharmProjects\password-manager-start\venv\lib\site-packages\flask\globals.py", line 56, in <module>
    app_ctx: "AppContext" = LocalProxy(  # type: ignore[assignment]
TypeError: LocalProxy.__init__() got an unexpected keyword argument 'unbound_message'

This error message has only started to appear a few hours ago. I also get the same error message on previous work when I try to run the programs. So far I have been unable to figure out what the cause of this error message is or how I can go about dealing with the problem. Any help and advice would be much appreciated. Thank you.

Hi y'all,

I'm not sure if this is the right place for this question, but none of the other python subs looked like the place to ask.

I have been working with Supabase lately. I haven't used the controller I made for it in a couple weeks, but it was working fine then. I went to do something on it tonight and I'm getting this weird error:

ERROR:controllers.supabase_controller:Error inserting data into salesforce_opportunities_lake: SyncPostgrestClient.__init__() got an unexpected keyword argument 'verify'

Somehow a 'verify' argument is being passed to this class. I'm not passing it in, just the url and the key just like Supabase says to. I confirmed I have the updated Supabase package installed in my environment.

I tried to look around in stackoverflow and even used chatGPT but I couldn't find any solutions. chatGPT suggested to check the documentation for any changes but I can't find anything about a ghost inserting a keyword argument that isn't there (see code below). However, I'll be the first to admit that I am not good at comprehending documentation.

Here's the relevant portion of the Supabase controller I wrote:

import os
import logging
from supabase import create_client
from dotenv import load_dotenv

load_dotenv()

class SupabaseController:
    def __init__(self):
        self.url = os.environ.get('SUPABASE_URL')
        self.key = os.environ.get('SUPABASE_KEY')
        self.client = self._create_client()

        logging.basicConfig(level=logging.INFO)
        self.logger = logging.getLogger(__name__)

    def _create_client(self):
        '''
        Checks for the existence of environment variables and creates a Supabase client if they are set
        '''
        if not self.url or not self.key:
            raise ValueError('Supabase API key and URL must be set in environment variables')
        return create_client(self.url, self.key)
    
    def select_data_from_table(self, table_name):
        '''
        Selects data from the given table
        '''
        limit = 1000
        offset = 0
        all_data = []

        while True:
            try:
                data = self.client.table(table_name).select('*').range(offset, offset + limit -1).execute()

                if len(data.data) == 0:
                    self.logger.info(f"All data retrieved from {table_name}.")
                    break

                all_data.extend(data.data)
                offset += limit

                self.logger.info(f"Retrieved {len(all_data)} records from {table_name}.")
            except Exception as e:
                self.logger.error(f"Error retrieving data from {table_name}: {e}")
                break

        return all_data
    
    def insert_data_to_table(self, table_name, data):
        '''
        Inserts data to the given table
        '''
        try:
            response = self.client.table(table_name).insert(data).execute()
            if len(response.data) == 0:
                self.logger.warning(f"No data inserted to {table_name}.")
            else:
                self.logger.info(f"Data inserted into {table_name}.")
        except Exception as e:
            self.logger.error(f"Error inserting data into {table_name}: {e}")

I've double and triple checked the environment variables and they are correct.

And just to clarify - the _create_client() is operating, not throwing a valueerror. I'm getting the keyword errors on every item I try to insert into the table, also getting the error when I'm trying to select data from the table.

And here's the implementation:

from datetime import datetime
import pytz
from tqdm import tqdm

from controllers.salesforce_controller import SalesforceController
from controllers.supabase_controller import SupabaseController
from pipelines import query_strings

class SalesforcePipeline:
    def __init__(self):
        self.salesforce_controller = SalesforceController()
        self.supabase_controller = SupabaseController()

        self.table_name = 'salesforce_opportunities_lake'
        self.opportunities_query_string = query_strings.SALESFORCE_OPPORTUNITIES

    def opportunities_job(self):
        existing_opportuties = self.supabase_controller.select_data_from_table(table_name=self.table_name)
        opportunities_data = self.salesforce_controller.fetch_salesforce_data(self.opportunities_query_string)
        opportunities = self.parse_opportunities(opportunities_data)
        self.update_opportunities(existing_opportuties, opportunities)

# A bunch of code here not relevant to this question
    
    def update_opportunities(self, existing_opportuties, opportunities):
        '''
        Updates opportunities data in Supabase table
        '''
        existing_ids = [opportunity['opportunity_id'] for opportunity in existing_opportuties]

        for opportunity in tqdm(opportunities):
            if opportunity['opportunity_id'] in existing_ids:
                self.supabase_controller.update_data_in_table(table_name=self.table_name, data=opportunity, id=opportunity['opportunity_id'])
            else:
                self.supabase_controller.insert_data_to_table(table_name=self.table_name, data=opportunity)

main.py:

from pipelines.salesforce_pipeline import SalesforcePipeline

def update_lake():
    salesforce = SalesforcePipeline()
    salesforce.opportunities_job()

if __name__ == '__main__':
    update_lake()