Spaces:
Running
Running
Update services/state_manager.py
Browse files
services/state_manager.py
CHANGED
@@ -139,7 +139,7 @@ def process_and_store_bubble_token(url_user_token, org_urn, token_state):
|
|
139 |
for state_key, table_name in data_tables_to_fetch.items():
|
140 |
logging.info(f"Attempting to fetch {table_name} from Bubble for org_urn: {current_org_urn}")
|
141 |
try:
|
142 |
-
fetched_df, error_message = fetch_linkedin_posts_data_from_bubble(current_org_urn, table_name)
|
143 |
new_state[state_key] = pd.DataFrame() if error_message or fetched_df is None else fetched_df
|
144 |
if error_message: logging.warning(f"Error fetching {table_name} from Bubble: {error_message}.")
|
145 |
# Ensure date column in operations log is parsed correctly if it's fetched as string
|
|
|
139 |
for state_key, table_name in data_tables_to_fetch.items():
|
140 |
logging.info(f"Attempting to fetch {table_name} from Bubble for org_urn: {current_org_urn}")
|
141 |
try:
|
142 |
+
fetched_df, error_message = fetch_linkedin_posts_data_from_bubble(current_org_urn, table_name, "organization_urn")
|
143 |
new_state[state_key] = pd.DataFrame() if error_message or fetched_df is None else fetched_df
|
144 |
if error_message: logging.warning(f"Error fetching {table_name} from Bubble: {error_message}.")
|
145 |
# Ensure date column in operations log is parsed correctly if it's fetched as string
|