Move celery to tasks

h/cli/commands/celery.py

@@ -1,6 +1,6 @@
 import click
 
-from h.celery import start
+from h.tasks.celery import start
 
 
 @click.command(

h/tasks/annotations.py

@@ -1,7 +1,7 @@
-from h.celery import celery, get_task_logger
 from h.db.types import URLSafeUUID
 from h.models import Annotation
 from h.services.annotation_write import AnnotationWriteService
+from h.tasks.celery import celery, get_task_logger
 
 log = get_task_logger(__name__)
 

h/tasks/cleanup.py

@@ -4,7 +4,7 @@
 from sqlalchemy import func, select
 
 from h import models
-from h.celery import celery, get_task_logger
+from h.tasks.celery import celery, get_task_logger
 
 log = get_task_logger(__name__)
 

h/tasks/indexer.py

@@ -3,8 +3,8 @@
 import newrelic
 from celery import Task
 
-from h.celery import celery, get_task_logger
 from h.services import AnnotationSyncService
+from h.tasks.celery import celery, get_task_logger
 
 log = get_task_logger(__name__)
 

h/tasks/job_queue.py

@@ -1,4 +1,4 @@
-from h.celery import celery, get_task_logger
+from h.tasks.celery import celery, get_task_logger
 
 log = get_task_logger(__name__)
 

h/tasks/mailer.py

@@ -9,7 +9,7 @@
 import pyramid_mailer
 import pyramid_mailer.message
 
-from h.celery import celery, get_task_logger
+from h.tasks.celery import celery, get_task_logger
 
 __all__ = ("send",)
 

h/tasks/url_migration.py

@@ -1,4 +1,4 @@
-from h.celery import celery
+from h.tasks.celery import celery
 
 
 @celery.task(rate_limit="10/m")

tests/unit/h/celery_test.py

@@ -2,7 +2,7 @@
 
 from billiard.einfo import ExceptionInfo
 
-from h import celery
+from h.tasks import celery
 
 
 class TestCelery: