AlainDeLong commited on
Commit
3ab87df
·
1 Parent(s): 526605e

chore: remove qstash receiver

Browse files
app/api/endpoints/analysis.py CHANGED
@@ -11,7 +11,7 @@ import pandas as pd
11
  from trendspy import Trends
12
 
13
  from app.core.config import settings
14
- from app.core.clients import qstash_client, qstash_receiver
15
  from app.schemas.analysis_schema import (
16
  WeeklyTrendResponseSchema,
17
  WeeklyTrendListResponse,
 
11
  from trendspy import Trends
12
 
13
  from app.core.config import settings
14
+ from app.core.clients import qstash_client
15
  from app.schemas.analysis_schema import (
16
  WeeklyTrendResponseSchema,
17
  WeeklyTrendListResponse,
app/core/clients.py CHANGED
@@ -5,8 +5,8 @@ from app.core.config import settings
5
  # qstash_client = QStash(token=settings.QSTASH_TOKEN, base_url=settings.QSTASH_URL)
6
  qstash_client = QStash(token=settings.QSTASH_TOKEN)
7
 
8
- # Initialize the QStash receiver for verifying incoming messages
9
- qstash_receiver = Receiver(
10
- current_signing_key=settings.QSTASH_CURRENT_SIGNING_KEY,
11
- next_signing_key=settings.QSTASH_NEXT_SIGNING_KEY,
12
- )
 
5
  # qstash_client = QStash(token=settings.QSTASH_TOKEN, base_url=settings.QSTASH_URL)
6
  qstash_client = QStash(token=settings.QSTASH_TOKEN)
7
 
8
+ # # Initialize the QStash receiver for verifying incoming messages
9
+ # qstash_receiver = Receiver(
10
+ # current_signing_key=settings.QSTASH_CURRENT_SIGNING_KEY,
11
+ # next_signing_key=settings.QSTASH_NEXT_SIGNING_KEY,
12
+ # )
app/core/config.py CHANGED
@@ -43,6 +43,8 @@ class Settings(BaseSettings):
43
  # QStash Settings
44
  QSTASH_URL: str = "https://qstash.upstash.io"
45
  QSTASH_TOKEN: str
 
 
46
 
47
  # Base URL for the application, used for constructing callback URLs
48
  BASE_URL: str = "http://localhost:8000"
 
43
  # QStash Settings
44
  QSTASH_URL: str = "https://qstash.upstash.io"
45
  QSTASH_TOKEN: str
46
+ # QSTASH_CURRENT_SIGNING_KEY: str
47
+ # QSTASH_NEXT_SIGNING_KEY: str
48
 
49
  # Base URL for the application, used for constructing callback URLs
50
  BASE_URL: str = "http://localhost:8000"