File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -39,8 +39,8 @@ class TaskiqAdminMiddleware(TaskiqMiddleware):
39
39
""" """
40
40
async with httpx.AsyncClient() as client:
41
41
await client.post(
42
- headers = {" access-token" : settings.taskiq_admin_access_token },
43
- url = urljoin(settings.taskiq_admin_url , f " /api/tasks/ { message.task_id} /started " ),
42
+ headers = {" access-token" : TASKIQ_ADMIN_API_TOKEN },
43
+ url = urljoin(TASKIQ_ADMIN_URL , f " /api/tasks/ { message.task_id} /started " ),
44
44
json = {
45
45
" args" : message.args,
46
46
" kwargs" : message.kwargs,
@@ -60,8 +60,8 @@ class TaskiqAdminMiddleware(TaskiqMiddleware):
60
60
""" """
61
61
async with httpx.AsyncClient() as client:
62
62
await client.post(
63
- headers = {" access-token" : settings.taskiq_admin_access_token },
64
- url = urljoin(settings.taskiq_admin_url , f " /api/tasks/ { message.task_id} /executed " ),
63
+ headers = {" access-token" : TASKIQ_ADMIN_API_TOKEN },
64
+ url = urljoin(TASKIQ_ADMIN_URL , f " /api/tasks/ { message.task_id} /executed " ),
65
65
json = {
66
66
" error" : result.error
67
67
if result.error is None
You can’t perform that action at this time.
0 commit comments