-
-
Save daviddavis/f1426796a19c73fb081840dee0fd4854 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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