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 (Optional[str])
- 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 (Optional[Union[str, IO[AnyStr]]])
session (Optional[requests.Session])
token (Optional[gcloud.aio.auth.Token])
api_root (Optional[str])
- _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 (Optional[requests.Session])
timeout (int)
- Return type:
Any
- async delete(tname, session=None, timeout=10)¶
- Parameters:
tname (str)
session (Optional[requests.Session])
timeout (int)
- Return type:
Any
- async get(tname, full=False, session=None, timeout=10)¶
- Parameters:
tname (str)
full (bool)
session (Optional[requests.Session])
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 (Optional[requests.Session])
timeout (int)
- Return type:
Any
- async run(tname, full=False, session=None, timeout=10)¶
- Parameters:
tname (str)
full (bool)
session (Optional[requests.Session])
timeout (int)
- Return type:
Any
- async close()¶
- Return type:
None
- async __aexit__(*args)¶
- Parameters:
args (Any)
- Return type:
None