taskqueue.queue¶
An asynchronous push queue for Google Appengine Task Queues
Attributes¶
Classes¶
Functions¶
|
Module Contents¶
- taskqueue.queue.SCOPES = ['https://www.googleapis.com/auth/cloud-tasks']¶
- taskqueue.queue.log¶
- taskqueue.queue.init_api_root(api_root)¶
- Parameters:
api_root (str | None)
- Return type:
tuple[bool, str]
- class taskqueue.queue.PushQueue(project, taskqueue, location='us-central1', service_file=None, session=None, token=None, api_root=None)¶
- Parameters:
project (str)
taskqueue (str)
location (str)
service_file (str | IO[AnyStr] | None)
session (requests.Session | None)
token (gcloud.aio.auth.Token | None)
api_root (str | None)
- _api_root: str¶
- _api_is_dev: bool¶
- _queue_path: str¶
- session¶
- token¶
- async headers()¶
- Return type:
dict[str, str]
- task_name(task_id)¶
- Parameters:
task_id (str)
- Return type:
str
- async create(task, session=None, timeout=10)¶
- Parameters:
task (dict[str, Any])
session (requests.Session | None)
timeout (int)
- Return type:
Any
- async delete(tname, session=None, timeout=10)¶
- Parameters:
tname (str)
session (requests.Session | None)
timeout (int)
- Return type:
Any
- async get(tname, full=False, session=None, timeout=10)¶
- Parameters:
tname (str)
full (bool)
session (requests.Session | None)
timeout (int)
- Return type:
Any
- async list(full=False, page_size=1000, page_token='', session=None, timeout=10)¶
- Parameters:
full (bool)
page_size (int)
page_token (str)
session (requests.Session | None)
timeout (int)
- Return type:
Any
- async run(tname, full=False, session=None, timeout=10)¶
- Parameters:
tname (str)
full (bool)
session (requests.Session | None)
timeout (int)
- Return type:
Any
- async close()¶
- Return type:
None
- async __aexit__(*args)¶
- Parameters:
args (Any)
- Return type:
None