call HandleJobs() when RunJob() finished to run any dependant jobs
This commit is contained in:
5
TODO
5
TODO
@@ -3,11 +3,6 @@ DDP:
|
|||||||
sess={}
|
sess={}
|
||||||
sess[job.id]=Session()
|
sess[job.id]=Session()
|
||||||
etc
|
etc
|
||||||
Then when we finish 1 job, we need to force 'wake-up' / run any dependant jobs
|
|
||||||
|
|
||||||
move scan now and force scan over to new file structures
|
|
||||||
- scan now is over, but job-id's should be hrefs... need to last_import_date=0 for all Dirs, then call ProcessImportDirs for force scan
|
|
||||||
optimise gen hash / thumbs to only process dirs with new content
|
|
||||||
|
|
||||||
### DB
|
### DB
|
||||||
|
|
||||||
|
|||||||
@@ -243,6 +243,8 @@ def RunJob(job):
|
|||||||
JobGetFileDetails(job)
|
JobGetFileDetails(job)
|
||||||
else:
|
else:
|
||||||
print("ERROR: Requested to process unknown job type: {}".format(job.name))
|
print("ERROR: Requested to process unknown job type: {}".format(job.name))
|
||||||
|
# okay, we finished a job, so check for any jobs that are dependant on this and run them...
|
||||||
|
HandleJobs()
|
||||||
return
|
return
|
||||||
|
|
||||||
def FinishJob(job, last_log, state="Completed", pa_job_state="Completed"):
|
def FinishJob(job, last_log, state="Completed", pa_job_state="Completed"):
|
||||||
|
|||||||
Reference in New Issue
Block a user