Commit 290379d5 authored by Antoine Millet's avatar Antoine Millet
Browse files

Added jobs management handlers.

parent cf27e758
Loading
Loading
Loading
Loading
+32 −0
Original line number Diff line number Diff line
@@ -508,6 +508,38 @@ class CliHandler(OnlineCCHandler):
                
        return errs.get_dict()

    @listed
    def jobs(self, conn, done=None):
        '''
        Return all jobs.
        '''

        jobs = []
        for job in self._server.jobs.iterjobs(done):
            jobs.append(job.export())

        return jobs

    @listed
    def cancel(self, conn, jobid):
        '''
        Cancel a job.
        '''

        self._server.jobs.cancel(jobid)

    @listed
    def jobspurge(self, conn):
        '''
        Purge all done jobs from the job list.
        '''

        self._server.jobs.purge()

    def threads(self, conn):
        import threading
        return threading.active_count()

    @listed
    def dbstats(self, conn):
        '''