Skip to content

Instantly share code, notes, and snippets.

@daviddavis
Created August 31, 2017 14:50
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save daviddavis/f1426796a19c73fb081840dee0fd4854 to your computer and use it in GitHub Desktop.
Save daviddavis/f1426796a19c73fb081840dee0fd4854 to your computer and use it in GitHub Desktop.
diff --git a/server/pulp/server/controllers/repository.py b/server/pulp/server/controllers/repository.py
index 7a5f4ac..9927a5f 100644
--- a/server/pulp/server/controllers/repository.py
+++ b/server/pulp/server/controllers/repository.py
@@ -712,6 +712,12 @@ def queue_sync_with_auto_publish(repo_id, overrides=None, scheduled_call_id=None
return result
+@celery.task(base=PulpTask, name='pulp.server.tasks.repository.sleepy_time')
+def sleepy_time():
+ import time
+ time.sleep(2)
+
+
@celery.task(base=Task, name='pulp.server.managers.repo.sync.sync')
def sync(repo_id, sync_config_override=None, scheduled_call_id=None):
"""
diff --git a/server/pulp/server/webservices/views/repositories.py b/server/pulp/server/webservices/views/repositories.py
index d051685..900c61e 100644
--- a/server/pulp/server/webservices/views/repositories.py
+++ b/server/pulp/server/webservices/views/repositories.py
@@ -1054,6 +1054,8 @@ class RepoSync(View):
overrides = request.body_as_json.get('override_config', None)
model.Repository.objects.get_repo_or_missing_resource(repo_id)
+ for i in xrange(200):
+ async_result = repo_controller.sleepy_time.apply_async()
async_result = repo_controller.queue_sync_with_auto_publish(repo_id, overrides)
raise exceptions.OperationPostponed(async_result)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment