rename to fastapi-cloud-tasks

Author: ofpiyush

README.md

@@ -1,16 +1,16 @@
-# Gelery
+# FastAPI Cloud Tasks
 
 GCP's Cloud Tasks + FastAPI = Replacement for celery's async delayed tasks.
 
-Gelery + Cloud Run = Autoscaled delayed tasks.
+FastAPI Cloud Tasks + Cloud Run = Autoscaled delayed tasks.
 
 ## Concept
 
 [`Cloud Tasks`](https://cloud.google.com/tasks) allows us to schedule a HTTP request in the future.
 
 [FastAPI](https://fastapi.tiangolo.com/tutorial/body/) makes us define complete schema and params for an HTTP endpoint.
 
-Gelery works by putting the two together:
+FastAPI Cloud Tasks works by putting the two together:
 
 - It adds a `.delay` method to existing routes on FastAPI.
 - When this method is called, it schedules a request with Cloud Tasks.
@@ -151,7 +151,7 @@ TaskRoute = TaskRouteBuilder(
     pre_create_hook=oidc_hook(
         token=tasks_v2.OidcToken(
             # Service account that you created
-            service_account_email="gelery@gcp-project-id.iam.gserviceaccount.com",
+            service_account_email="fastapi-cloud-tasks@gcp-project-id.iam.gserviceaccount.com",
             audience=base_url,
         ),
     ),

examples/full/settings.py

@@ -1,14 +1,14 @@
 import os
 
-from gelery.utils import queue_path
+from fastapi_cloud_tasks.utils import queue_path
 from google.cloud import tasks_v2
 
 TASK_LISTENER_BASE_URL = os.getenv("TASK_LISTENER_BASE_URL", default="http://example.com")
 TASK_PROJECT_ID = os.getenv("TASK_PROJECT_ID", default="sample-project")
 TASK_LOCATION = os.getenv("TASK_LOCATION", default="asia-south1")
 TASK_QUEUE = os.getenv("TASK_QUEUE", default="test-queue")
 
-TASK_SERVICE_ACCOUNT = os.getenv("TASK_SERVICE_ACCOUNT", default=f"gelery@{TASK_PROJECT_ID}.iam.gserviceaccount.com")
+TASK_SERVICE_ACCOUNT = os.getenv("TASK_SERVICE_ACCOUNT", default=f"fastapi-cloud-tasks@{TASK_PROJECT_ID}.iam.gserviceaccount.com")
 
 TASK_QUEUE_PATH = queue_path(
     project=TASK_PROJECT_ID,

examples/full/tasks.py

@@ -4,8 +4,8 @@
 from examples.full.settings import TASK_LISTENER_BASE_URL, TASK_OIDC_TOKEN, TASK_QUEUE_PATH
 from fastapi import FastAPI
 from fastapi.routing import APIRouter
-from gelery.hooks import chained_hook, deadline_hook, oidc_hook
-from gelery.taskroute import TaskRouteBuilder
+from fastapi_cloud_tasks.hooks import chained_hook, deadline_hook, oidc_hook
+from fastapi_cloud_tasks.taskroute import TaskRouteBuilder
 from google.protobuf import duration_pb2
 
 app = FastAPI()

examples/simple/main.py

@@ -3,8 +3,8 @@
 
 from fastapi import FastAPI
 from fastapi.routing import APIRouter
-from gelery.taskroute import TaskRouteBuilder
-from gelery.utils import queue_path
+from fastapi_cloud_tasks.taskroute import TaskRouteBuilder
+from fastapi_cloud_tasks.utils import queue_path
 from pydantic import BaseModel
 
 TaskRoute = TaskRouteBuilder(

gelery/__init__.py renamed to fastapi_cloud_tasks/__init__.py

@@ -9,9 +9,9 @@
 from google.cloud import tasks_v2
 from google.protobuf import timestamp_pb2
 
-from gelery.exception import MissingParamError, WrongTypeError
-from gelery.hooks import Hook
-from gelery.utils import err_val, taskMethod
+from fastapi_cloud_tasks.exception import MissingParamError, WrongTypeError
+from fastapi_cloud_tasks.hooks import Hook
+from fastapi_cloud_tasks.utils import err_val, taskMethod
 
 try:
     import ujson as json

gelery/decorators.py renamed to fastapi_cloud_tasks/decorators.py

@@ -5,8 +5,8 @@
 from fastapi.routing import APIRoute
 from google.cloud import tasks_v2
 
-from gelery.delayer import Delayer
-from gelery.hooks import Hook, noop_hook
+from fastapi_cloud_tasks.delayer import Delayer
+from fastapi_cloud_tasks.hooks import Hook, noop_hook
 
 
 def TaskRouteBuilder(