workers: move landing_worker module (bug 1819145) (#275)

Author: zzzeid

landoapi/cli.py

@@ -91,7 +91,7 @@ def landing_worker():
     for system in get_subsystems(exclude=exclusions):
         system.ensure_ready()
 
-    from landoapi.landing_worker import LandingWorker
+    from landoapi.workers.landing_worker import LandingWorker
 
     worker = LandingWorker()
     worker.start()

landoapi/workers/__init__.py

@@ -0,0 +1,3 @@
+# This Source Code Form is subject to the terms of the Mozilla Public
+# License, v. 2.0. If a copy of the MPL was not distributed with this
+# file, You can obtain one at http://mozilla.org/MPL/2.0/.

landoapi/landing_worker.py landoapi/workers/landing_worker.pylandoapi/landing_worker.py renamed to landoapi/workers/landing_worker.py

@@ -10,7 +10,7 @@
 
 from landoapi import patches
 from landoapi.hg import AUTOFORMAT_COMMIT_MESSAGE, HgRepo
-from landoapi.landing_worker import LandingWorker
+from landoapi.workers.landing_worker import LandingWorker
 from landoapi.models.landing_job import LandingJob, LandingJobStatus
 from landoapi.models.transplant import Transplant, TransplantStatus
 from landoapi.repos import Repo, SCM_LEVEL_3
@@ -382,7 +382,7 @@ def test_integrated_execute_job(
     # Mock `phab_trigger_repo_update` so we can make sure that it was called.
     mock_trigger_update = mock.MagicMock()
     monkeypatch.setattr(
-        "landoapi.landing_worker.LandingWorker.phab_trigger_repo_update",
+        "landoapi.workers.landing_worker.LandingWorker.phab_trigger_repo_update",
         mock_trigger_update,
     )
 
@@ -463,7 +463,7 @@ def test_failed_landing_job_notification(
     # Mock `notify_user_of_landing_failure` so we can make sure that it was called.
     mock_notify = mock.MagicMock()
     monkeypatch.setattr(
-        "landoapi.landing_worker.notify_user_of_landing_failure", mock_notify
+        "landoapi.workers.landing_worker.notify_user_of_landing_failure", mock_notify
     )
 
     assert worker.run_job(job, repo, hgrepo, treestatus, "landoapi.test.bucket")
@@ -569,7 +569,7 @@ def test_format_patch_success_unchanged(
     # Mock `phab_trigger_repo_update` so we can make sure that it was called.
     mock_trigger_update = mock.MagicMock()
     monkeypatch.setattr(
-        "landoapi.landing_worker.LandingWorker.phab_trigger_repo_update",
+        "landoapi.workers.landing_worker.LandingWorker.phab_trigger_repo_update",
         mock_trigger_update,
     )
 
@@ -634,7 +634,7 @@ def test_format_single_success_changed(
     # Mock `phab_trigger_repo_update` so we can make sure that it was called.
     mock_trigger_update = mock.MagicMock()
     monkeypatch.setattr(
-        "landoapi.landing_worker.LandingWorker.phab_trigger_repo_update",
+        "landoapi.workers.landing_worker.LandingWorker.phab_trigger_repo_update",
         mock_trigger_update,
     )
 
@@ -718,7 +718,7 @@ def test_format_stack_success_changed(
     # Mock `phab_trigger_repo_update` so we can make sure that it was called.
     mock_trigger_update = mock.MagicMock()
     monkeypatch.setattr(
-        "landoapi.landing_worker.LandingWorker.phab_trigger_repo_update",
+        "landoapi.workers.landing_worker.LandingWorker.phab_trigger_repo_update",
         mock_trigger_update,
     )
 
@@ -799,7 +799,7 @@ def test_format_patch_fail(
     # Mock `notify_user_of_landing_failure` so we can make sure that it was called.
     mock_notify = mock.MagicMock()
     monkeypatch.setattr(
-        "landoapi.landing_worker.notify_user_of_landing_failure", mock_notify
+        "landoapi.workers.landing_worker.notify_user_of_landing_failure", mock_notify
     )
 
     assert not worker.run_job(
@@ -857,14 +857,14 @@ def test_format_patch_no_landoini(
     # Mock `phab_trigger_repo_update` so we can make sure that it was called.
     mock_trigger_update = mock.MagicMock()
     monkeypatch.setattr(
-        "landoapi.landing_worker.LandingWorker.phab_trigger_repo_update",
+        "landoapi.workers.landing_worker.LandingWorker.phab_trigger_repo_update",
         mock_trigger_update,
     )
 
     # Mock `notify_user_of_landing_failure` so we can make sure that it was called.
     mock_notify = mock.MagicMock()
     monkeypatch.setattr(
-        "landoapi.landing_worker.notify_user_of_landing_failure", mock_notify
+        "landoapi.workers.landing_worker.notify_user_of_landing_failure", mock_notify
     )
 
     assert worker.run_job(job, repo, hgrepo, treestatus, "landoapi.test.bucket")