From 3ff7c6b9c12f250f9dc828a5898c7944b02ef4c7 Mon Sep 17 00:00:00 2001 From: erinspace Date: Thu, 11 Jun 2015 14:48:45 -0400 Subject: [PATCH] Add inv task for migrate to v2 thing --- tasks.py | 6 ++++++ 1 file changed, 6 insertions(+) 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'")