#!/usr/bin/python2.5

#

# Copyright 2008 the Melange authors.

#

# Licensed under the Apache License, Version 2.0 (the "License");

# you may not use this file except in compliance with the License.

# You may obtain a copy of the License at

#

#   http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.

"""Helpers functions for dealing with task queue api

"""

__authors__ = [

  '"Daniel Hans" <daniel.m.hans@gmail.com>',

  ]

import logging

from django import http

# TODO(labs): fix when taskqueue graduates from labs

from google.appengine.api.labs import taskqueue

class Error(Exception):

  """Base class for all exceptions raised by this module.

  """

  pass

class FatalTaskError(Error):

  """Class for all errors that lead to immediate task abortion.

  """

  pass

def startTask(url, queue_name='default', context=None, **kwargs):

  """Adds a new task to one of the queues

  """

  queue = taskqueue.Queue(name=queue_name)

  return queue.add(taskqueue.Task(url=url, params=context))

def terminateTask():

  """Generates http response which causes that the task is

     is not added to the queue again

  """

  return http.HttpResponse(status=200)

def repeatTask():

  """Generates http response which causes that the task is

     added to the queue again

  """

  return http.HttpResponse(status=500)