taskqueue.queue

An asynchronous push queue for Google Appengine Task Queues

Attributes

SCOPES

log

Classes

PushQueue

Functions

init_api_root(api_root)

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 __aenter__()
Return type:

PushQueue

async __aexit__(*args)
Parameters:

args (Any)

Return type:

None