@@ -76,7 +76,10 @@ def post(self, request, pk):
7676 datasource = get_object_or_404 (self .queryset , pk = pk )
7777 job = datasource .enqueue_sync_job (request )
7878
79- messages .success (request , f"Queued job #{ job .pk } to sync { datasource } " )
79+ messages .success (
80+ request ,
81+ _ ("Queued job #{id} to sync {datasource}" ).format (id = job .pk , datasource = datasource )
82+ )
8083 return redirect (datasource .get_absolute_url ())
8184
8285
@@ -235,7 +238,7 @@ def post(self, request, pk):
235238
236239 candidate_config = get_object_or_404 (ConfigRevision , pk = pk )
237240 candidate_config .activate ()
238- messages .success (request , f "Restored configuration revision #{ pk } " )
241+ messages .success (request , _ ( "Restored configuration revision #{id}" ). format ( id = pk ) )
239242
240243 return redirect (candidate_config .get_absolute_url ())
241244
@@ -379,9 +382,9 @@ def post(self, request, job_id):
379382 # Remove job id from queue and delete the actual job
380383 queue .connection .lrem (queue .key , 0 , job .id )
381384 job .delete ()
382- messages .success (request , f'Deleted job { job_id } ' )
385+ messages .success (request , _ ( 'Job {id} has been deleted.' ). format ( id = job_id ) )
383386 else :
384- messages .error (request , f 'Error deleting job: { form .errors [0 ]} ' )
387+ messages .error (request , _ ( 'Error deleting job {id} : {error}' ). format ( id = job_id , error = form .errors [0 ]) )
385388
386389 return redirect (reverse ('core:background_queue_list' ))
387390
@@ -394,13 +397,13 @@ def get(self, request, job_id):
394397 try :
395398 job = RQ_Job .fetch (job_id , connection = get_redis_connection (config ['connection_config' ]),)
396399 except NoSuchJobError :
397- raise Http404 (_ ("Job {job_id } not found" ).format (job_id = job_id ))
400+ raise Http404 (_ ("Job {id } not found. " ).format (id = job_id ))
398401
399402 queue_index = QUEUES_MAP [job .origin ]
400403 queue = get_queue_by_index (queue_index )
401404
402405 requeue_job (job_id , connection = queue .connection , serializer = queue .serializer )
403- messages .success (request , f'You have successfully requeued: { job_id } ' )
406+ messages .success (request , _ ( 'Job {id} has been re-enqueued.' ). format ( id = job_id ) )
404407 return redirect (reverse ('core:background_task' , args = [job_id ]))
405408
406409
@@ -412,7 +415,7 @@ def get(self, request, job_id):
412415 try :
413416 job = RQ_Job .fetch (job_id , connection = get_redis_connection (config ['connection_config' ]),)
414417 except NoSuchJobError :
415- raise Http404 (_ ("Job {job_id } not found" ).format (job_id = job_id ))
418+ raise Http404 (_ ("Job {id } not found. " ).format (id = job_id ))
416419
417420 queue_index = QUEUES_MAP [job .origin ]
418421 queue = get_queue_by_index (queue_index )
@@ -435,7 +438,7 @@ def get(self, request, job_id):
435438 registry = ScheduledJobRegistry (queue .name , queue .connection )
436439 registry .remove (job )
437440
438- messages .success (request , f'You have successfully enqueued: { job_id } ' )
441+ messages .success (request , _ ( 'Job {id} has been enqueued.' ). format ( id = job_id ) )
439442 return redirect (reverse ('core:background_task' , args = [job_id ]))
440443
441444
@@ -452,11 +455,11 @@ def get(self, request, job_id):
452455 queue_index = QUEUES_MAP [job .origin ]
453456 queue = get_queue_by_index (queue_index )
454457
455- stopped , _ = stop_jobs (queue , job_id )
456- if len (stopped ) == 1 :
457- messages .success (request , f'You have successfully stopped { job_id } ' )
458+ stopped_jobs = stop_jobs (queue , job_id )[ 0 ]
459+ if len (stopped_jobs ) == 1 :
460+ messages .success (request , _ ( 'Job {id} has been stopped.' ). format ( id = job_id ) )
458461 else :
459- messages .error (request , f 'Failed to stop { job_id } ' )
462+ messages .error (request , _ ( 'Failed to stop job {id}' ). format ( id = job_id ) )
460463
461464 return redirect (reverse ('core:background_task' , args = [job_id ]))
462465
0 commit comments