graphai.celery.common.jobs module

graphai.celery.common.jobs.direct_lookup_generic_job(task_fn, token, return_results=False, timeout=40, *args)

Launches a direct cache lookup job :param task_fn: The task function of the cache lookup :param token: The token to look up in the cache :param return_results: If True, the full results are returned instead of just the task id :param timeout: Timeout of cache lookup, in seconds

Returns:

The id of the cache lookup task in case of a cache hit, None in case of a miss