diff --git a/README.md b/README.md
index ba97d1dc5..09ed96009 100644
--- a/README.md
+++ b/README.md
@@ -23,7 +23,7 @@ report bugs and feature requests on GitHub using the above URL.
 - `python3-jira`
 - `python3-kobo-client`
 - `python3-kobo-django`
-- `python3-kobo-hub >= 0.26.0`
+- `python3-kobo-hub >= 0.32.0`
 - `python3-kobo-rpmlib`
 - `python3-mod_wsgi`
 - `python3-psycopg2`
@@ -36,7 +36,7 @@ report bugs and feature requests on GitHub using the above URL.
 - `koji`
 - `python3-kobo-client`
 - `python3-kobo-rpmlib`
-- `python3-kobo-worker >= 0.30.0`
+- `python3-kobo-worker >= 0.32.0`
 
 ### client:
 - `koji`
diff --git a/osh.spec b/osh.spec
index e877b958a..c5818f3e2 100644
--- a/osh.spec
+++ b/osh.spec
@@ -62,7 +62,7 @@ Requires: file
 Requires: koji
 Requires: python3-kobo-client
 Requires: python3-kobo-rpmlib
-Requires: python3-kobo-worker >= 0.30.0
+Requires: python3-kobo-worker >= 0.32.0
 Requires: %{name}-common = %{version}-%{release}
 Requires: osh-worker-conf
 
@@ -79,7 +79,7 @@ Requires: mod_ssl
 Requires: python3-django >= %{min_required_version_django}
 Requires: python3-kobo-client
 Requires: python3-kobo-django
-Requires: python3-kobo-hub >= 0.26.0
+Requires: python3-kobo-hub >= 0.32.0
 Requires: python3-kobo-rpmlib
 Requires: python3-mod_wsgi
 # PostgreSQL adapter for python
diff --git a/osh/worker/tasks/task_build.py b/osh/worker/tasks/task_build.py
index 19ba653df..b2400e164 100644
--- a/osh/worker/tasks/task_build.py
+++ b/osh/worker/tasks/task_build.py
@@ -35,8 +35,7 @@ def run(self):
 
         # scan base
         if base_task_args:
-            subtask_id = self.spawn_subtask(*base_task_args)
-            self.hub.worker.assign_task(subtask_id)
+            self.spawn_subtask(*base_task_args, inherit_worker=True)
             self.wait()
 
         if upload_id:
diff --git a/osh/worker/tasks/task_errata_diff_build.py b/osh/worker/tasks/task_errata_diff_build.py
index 8f19e74cb..9f5b0be98 100644
--- a/osh/worker/tasks/task_errata_diff_build.py
+++ b/osh/worker/tasks/task_errata_diff_build.py
@@ -40,17 +40,16 @@ def run(self):
         # update analyzers version cache if needed
         cache_task_args = self.hub.worker.ensure_cache(mock_config, scanning_session_id)
         if cache_task_args is not None:
-            cache_subtask_id = self.spawn_subtask(*cache_task_args)
-            self.hub.worker.assign_task(cache_subtask_id)
+            self.spawn_subtask(*cache_task_args, inherit_worker=True)
             self.wait()
 
         # (re)scan base if needed
         base_task_args = self.hub.worker.ensure_base_is_scanned_properly(scan_id, self.task_id)
         if base_task_args is not None:
             self.hub.worker.set_scan_to_basescanning(scan_id)
-            subtask_id = self.spawn_subtask(*base_task_args)
+
+            subtask_id = self.spawn_subtask(*base_task_args, inherit_worker=True)
             self.hub.worker.create_sb(subtask_id)
-            self.hub.worker.assign_task(subtask_id)
 
             self.wait()
             self.hub.worker.set_scan_to_scanning(scan_id)