Fixed Jobs/StartNow
This commit is contained in:
parent
eebe25a378
commit
ae5be31c89
@ -62,6 +62,12 @@ public abstract class Job : GlobalBase
|
|||||||
this.lastExecution = DateTime.Now;
|
this.lastExecution = DateTime.Now;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void ExecuteNow()
|
||||||
|
{
|
||||||
|
ResetProgress();
|
||||||
|
this.lastExecution = DateTime.UnixEpoch;
|
||||||
|
}
|
||||||
|
|
||||||
public void Cancel()
|
public void Cancel()
|
||||||
{
|
{
|
||||||
Log($"Cancelling {this}");
|
Log($"Cancelling {this}");
|
||||||
|
@ -130,6 +130,7 @@ public class JobBoss : GlobalBase
|
|||||||
Queue<Job> connectorJobQueue = mangaConnectorJobQueue[job.mangaConnector];
|
Queue<Job> connectorJobQueue = mangaConnectorJobQueue[job.mangaConnector];
|
||||||
if(!connectorJobQueue.Contains(job))
|
if(!connectorJobQueue.Contains(job))
|
||||||
connectorJobQueue.Enqueue(job);
|
connectorJobQueue.Enqueue(job);
|
||||||
|
job.ExecuteNow();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void AddJobsToQueue(IEnumerable<Job> jobs)
|
public void AddJobsToQueue(IEnumerable<Job> jobs)
|
||||||
|
Loading…
Reference in New Issue
Block a user