@@ -773,7 +773,10 @@ class IntegrationsTests(TestCase):
773
773
fixtures = ['eric.json' , 'test_data.json' ]
774
774
775
775
def setUp (self ):
776
- self .project = get (Project )
776
+ self .project = get (
777
+ Project ,
778
+ build_queue = None ,
779
+ )
777
780
self .feature_flag = get (
778
781
Feature ,
779
782
projects = [self .project ],
@@ -847,6 +850,31 @@ def test_webhook_skipped_project(self, trigger_build):
847
850
self .assertEqual (response .status_code , status .HTTP_406_NOT_ACCEPTABLE )
848
851
self .assertFalse (trigger_build .called )
849
852
853
+ @mock .patch ('readthedocs.core.views.hooks.sync_repository_task' )
854
+ def test_sync_repository_custom_project_queue (self , sync_repository_task , trigger_build ):
855
+ client = APIClient ()
856
+ self .project .build_queue = 'specific-build-queue'
857
+ self .project .save ()
858
+
859
+ headers = {GITHUB_EVENT_HEADER : GITHUB_CREATE }
860
+ resp = client .post (
861
+ '/api/v2/webhook/github/{}/' .format (self .project .slug ),
862
+ self .github_payload ,
863
+ format = 'json' ,
864
+ ** headers ,
865
+ )
866
+ self .assertEqual (resp .status_code , status .HTTP_200_OK )
867
+ self .assertFalse (resp .data ['build_triggered' ])
868
+ self .assertEqual (resp .data ['project' ], self .project .slug )
869
+ self .assertEqual (resp .data ['versions' ], [LATEST ])
870
+ self .assertTrue (resp .data ['versions_synced' ])
871
+ trigger_build .assert_not_called ()
872
+ latest_version = self .project .versions .get (slug = LATEST )
873
+ sync_repository_task .apply_async .assert_called_with (
874
+ (latest_version .pk ,),
875
+ queue = 'specific-build-queue' ,
876
+ )
877
+
850
878
def test_github_webhook_for_branches (self , trigger_build ):
851
879
"""GitHub webhook API."""
852
880
client = APIClient ()
@@ -927,7 +955,7 @@ def test_github_webhook_no_build_on_delete(self, sync_repository_task, trigger_b
927
955
self .assertEqual (resp .data ['versions' ], [LATEST ])
928
956
trigger_build .assert_not_called ()
929
957
latest_version = self .project .versions .get (slug = LATEST )
930
- sync_repository_task .delay .assert_called_with (latest_version .pk )
958
+ sync_repository_task .apply_async .assert_called_with (( latest_version .pk ,) )
931
959
932
960
@mock .patch ('readthedocs.core.views.hooks.sync_repository_task' )
933
961
def test_github_create_event (self , sync_repository_task , trigger_build ):
@@ -946,7 +974,7 @@ def test_github_create_event(self, sync_repository_task, trigger_build):
946
974
self .assertEqual (resp .data ['versions' ], [LATEST ])
947
975
trigger_build .assert_not_called ()
948
976
latest_version = self .project .versions .get (slug = LATEST )
949
- sync_repository_task .delay .assert_called_with (latest_version .pk )
977
+ sync_repository_task .apply_async .assert_called_with (( latest_version .pk ,) )
950
978
951
979
@mock .patch ('readthedocs.core.utils.trigger_build' )
952
980
def test_github_pull_request_opened_event (self , trigger_build , core_trigger_build ):
@@ -1191,7 +1219,7 @@ def test_github_delete_event(self, sync_repository_task, trigger_build):
1191
1219
self .assertEqual (resp .data ['versions' ], [LATEST ])
1192
1220
trigger_build .assert_not_called ()
1193
1221
latest_version = self .project .versions .get (slug = LATEST )
1194
- sync_repository_task .delay .assert_called_with (latest_version .pk )
1222
+ sync_repository_task .apply_async .assert_called_with (( latest_version .pk ,) )
1195
1223
1196
1224
def test_github_parse_ref (self , trigger_build ):
1197
1225
wh = GitHubWebhookView ()
@@ -1399,7 +1427,7 @@ def test_gitlab_push_hook_creation(
1399
1427
self .assertEqual (resp .data ['versions' ], [LATEST ])
1400
1428
trigger_build .assert_not_called ()
1401
1429
latest_version = self .project .versions .get (slug = LATEST )
1402
- sync_repository_task .delay .assert_called_with (latest_version .pk )
1430
+ sync_repository_task .apply_async .assert_called_with (( latest_version .pk ,) )
1403
1431
1404
1432
@mock .patch ('readthedocs.core.views.hooks.sync_repository_task' )
1405
1433
def test_gitlab_push_hook_deletion (
@@ -1421,7 +1449,7 @@ def test_gitlab_push_hook_deletion(
1421
1449
self .assertEqual (resp .data ['versions' ], [LATEST ])
1422
1450
trigger_build .assert_not_called ()
1423
1451
latest_version = self .project .versions .get (slug = LATEST )
1424
- sync_repository_task .delay .assert_called_with (latest_version .pk )
1452
+ sync_repository_task .apply_async .assert_called_with (( latest_version .pk ,) )
1425
1453
1426
1454
@mock .patch ('readthedocs.core.views.hooks.sync_repository_task' )
1427
1455
def test_gitlab_tag_push_hook_creation (
@@ -1444,7 +1472,7 @@ def test_gitlab_tag_push_hook_creation(
1444
1472
self .assertEqual (resp .data ['versions' ], [LATEST ])
1445
1473
trigger_build .assert_not_called ()
1446
1474
latest_version = self .project .versions .get (slug = LATEST )
1447
- sync_repository_task .delay .assert_called_with (latest_version .pk )
1475
+ sync_repository_task .apply_async .assert_called_with (( latest_version .pk ,) )
1448
1476
1449
1477
@mock .patch ('readthedocs.core.views.hooks.sync_repository_task' )
1450
1478
def test_gitlab_tag_push_hook_deletion (
@@ -1467,7 +1495,7 @@ def test_gitlab_tag_push_hook_deletion(
1467
1495
self .assertEqual (resp .data ['versions' ], [LATEST ])
1468
1496
trigger_build .assert_not_called ()
1469
1497
latest_version = self .project .versions .get (slug = LATEST )
1470
- sync_repository_task .delay .assert_called_with (latest_version .pk )
1498
+ sync_repository_task .apply_async .assert_called_with (( latest_version .pk ,) )
1471
1499
1472
1500
def test_gitlab_invalid_webhook (self , trigger_build ):
1473
1501
"""GitLab webhook unhandled event."""
@@ -1919,7 +1947,7 @@ def test_bitbucket_push_hook_creation(
1919
1947
self .assertEqual (resp .data ['versions' ], [LATEST ])
1920
1948
trigger_build .assert_not_called ()
1921
1949
latest_version = self .project .versions .get (slug = LATEST )
1922
- sync_repository_task .delay .assert_called_with (latest_version .pk )
1950
+ sync_repository_task .apply_async .assert_called_with (( latest_version .pk ,) )
1923
1951
1924
1952
@mock .patch ('readthedocs.core.views.hooks.sync_repository_task' )
1925
1953
def test_bitbucket_push_hook_deletion (
@@ -1938,7 +1966,7 @@ def test_bitbucket_push_hook_deletion(
1938
1966
self .assertEqual (resp .data ['versions' ], [LATEST ])
1939
1967
trigger_build .assert_not_called ()
1940
1968
latest_version = self .project .versions .get (slug = LATEST )
1941
- sync_repository_task .delay .assert_called_with (latest_version .pk )
1969
+ sync_repository_task .apply_async .assert_called_with (( latest_version .pk ,) )
1942
1970
1943
1971
def test_bitbucket_invalid_webhook (self , trigger_build ):
1944
1972
"""Bitbucket webhook unhandled event."""
0 commit comments