Main application to receive CRON requests

example_dataproc_main.py

import datetime

from flask import Flask, request
from google.appengine.api import taskqueue
from utils import process_url_date

app = Flask(__name__)

@app.route("/export_customers")
def export_customers():
    """When this method is invoked a new task is added to the queue where
    eventually data from BigQuery is exported to GCS.
    """
    date = process_url_date(request.args)
    task = taskqueue.add(url='/queue_export',
                         target='worker',
                         params={'date': date})
    return "Taks {} enqued, ETA {}".format(task.name, task.eta)