diff --git a/pyzeebe/task/task_builder.py b/pyzeebe/task/task_builder.py
index c40d4651..c9a1b91e 100644
--- a/pyzeebe/task/task_builder.py
+++ b/pyzeebe/task/task_builder.py
@@ -36,7 +36,7 @@ async def job_handler(job: Job) -> Job:
         job.variables.update(original_return_value)
         job.variables.pop(task_config.job_parameter_name, None)
         await job.set_running_after_decorators_status()
-        await after_decorator_runner(job)
+        job = await after_decorator_runner(job)
         if succeeded:
             await job.set_success_status()
         return job