Skip to content

Commit d9a23b3

Browse files
committed
fix for by query pipeline
1 parent 43e3b0f commit d9a23b3

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

dags/pipelines/notice_fetcher_pipelines.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ def notice_fetcher_by_query_pipeline(query: str = None) -> List[str]:
3737
from ted_sws.event_manager.services.log import log_error
3838
notice_ids = None
3939
try:
40-
ted_api_query = {"q": query}
40+
ted_api_query = {"query": query}
4141
mongodb_client = MongoClient(config.MONGO_DB_AUTH_URL)
4242
notice_ids = NoticeFetcher(notice_repository=NoticeRepository(mongodb_client=mongodb_client),
4343
ted_api_adapter=TedAPIAdapter(

0 commit comments

Comments
 (0)