diff --git a/tasks.py b/tasks.py
index 7df3c43d..084449ad 100644
--- a/tasks.py
+++ b/tasks.py
@@ -79,6 +79,12 @@ def migrate(migration, sources=None, kwargs_string=None, dry=True, async=False):
     migrate(migrate_func, **kwargs)
 
 
+@task
+def migrate_to_source_partition(dry=True, async=False):
+    from scrapi.tasks import migrate_to_source_partition
+    migrate_to_source_partition()
+
+
 @task
 def reset_search():
     run("curl -XPOST 'http://localhost:9200/_shutdown'")