diff --git a/roles/koji_hub/templates/fedmsg-koji-plugin.py b/roles/koji_hub/templates/fedmsg-koji-plugin.py
index ce8b7fb120..19a344a985 100644
--- a/roles/koji_hub/templates/fedmsg-koji-plugin.py
+++ b/roles/koji_hub/templates/fedmsg-koji-plugin.py
@@ -74,7 +74,8 @@ def get_message_body(topic, *args, **kws):
         msg['task_id'] = info.get('task_id', None)
 
         if msg['task_id']:
-            msg['request'] = kojihub.getTaskRequest(msg['task_id'])
+            task = kojihub.Task(msg['task_id'])
+            msg['request'] = task.getRequest()
         else:
             msg['request'] = None