mirror of
https://github.com/clearlinux/uwsgi.git
synced 2026-09-03 20:21:41 +00:00
34 lines
656 B
Python
34 lines
656 B
Python
#! /usr/bin/env python
|
|
# coding = utf-8
|
|
|
|
from __future__ import print_function
|
|
from spooler_priority_constants import tasks, LOGFILE
|
|
from os import remove
|
|
import uwsgi
|
|
|
|
counter = 0
|
|
|
|
|
|
def spoolerHandler(env):
|
|
global counter
|
|
# Spooler is handling a task
|
|
with open(LOGFILE, "a") as log:
|
|
print("%s" % (env['name']), file=log)
|
|
|
|
counter += 1
|
|
|
|
if counter == len(tasks):
|
|
# Each task has been processed.
|
|
uwsgi.signal(17)
|
|
|
|
# Spooler has done handling the task
|
|
return uwsgi.SPOOL_OK
|
|
|
|
uwsgi.spooler = spoolerHandler
|
|
|
|
# Clear the logfile
|
|
try:
|
|
remove(LOGFILE)
|
|
except OSError, e: # log does not exist
|
|
print(e)
|