@@ -264,13 +264,11 @@ async def cli_auth(auth_provider: str, code: str, state: str, db_context=Depends
264264 "Set DISCORD_CLUSTER_MANAGER_API_BASE_URL or POPCORN_API_URL." ,
265265 )
266266 redirect_uri_base = api_base_url .rstrip ("/" )
267- redirect_uri = f"https:// { redirect_uri_base } /auth/cli/{ auth_provider } "
267+ redirect_uri = f"{ redirect_uri_base } /auth/cli/{ auth_provider } "
268268
269269 user_id = None
270270 user_name = None
271271
272- print (redirect_uri )
273-
274272 try :
275273 if auth_provider == "discord" :
276274 user_id , user_name = await _handle_discord_oauth (code , redirect_uri )
@@ -333,18 +331,24 @@ async def _stream_submission_response(
333331
334332 while not task .done ():
335333 elapsed_time = time .time () - start_time
336- yield f"event: status\n data: { json .dumps ({'status' : 'processing' ,
337- 'elapsed_time' : round (elapsed_time , 2 )},
338- default = json_serializer )} \n \n "
334+ yield f"event: status\n data: {
335+ json .dumps (
336+ {'status' : 'processing' , 'elapsed_time' : round (elapsed_time , 2 )},
337+ default = json_serializer ,
338+ )
339+ } \n \n "
339340
340341 try :
341342 await asyncio .wait_for (asyncio .shield (task ), timeout = 15.0 )
342343 except asyncio .TimeoutError :
343344 continue
344345 except asyncio .CancelledError :
345- yield f"event: error\n data: { json .dumps (
346- {'status' : 'error' , 'detail' : 'Submission cancelled' },
347- default = json_serializer )} \n \n "
346+ yield f"event: error\n data: {
347+ json .dumps (
348+ {'status' : 'error' , 'detail' : 'Submission cancelled' },
349+ default = json_serializer ,
350+ )
351+ } \n \n "
348352 return
349353
350354 result , reports = await task
0 commit comments