mirror of
https://git.selfprivacy.org/SelfPrivacy/selfprivacy-rest-api.git
synced 2024-12-02 11:26:37 +00:00
58 lines
1.4 KiB
Python
58 lines
1.4 KiB
Python
|
import time
|
||
|
|
from selfprivacy_api.utils.huey import huey
|
||
|
|
from selfprivacy_api.jobs import JobStatus, Jobs
|
||
|
|
|
||
|
|
|
||
|
|
@huey.task()
|
||
|
|
def test_job():
|
||
|
|
job = Jobs.get_instance().add(
|
||
|
|
type_id="test",
|
||
|
|
name="Test job",
|
||
|
|
description="This is a test job.",
|
||
|
|
status=JobStatus.CREATED,
|
||
|
|
status_text="",
|
||
|
|
progress=0,
|
||
|
|
)
|
||
|
|
time.sleep(5)
|
||
|
|
Jobs.get_instance().update(
|
||
|
|
job=job,
|
||
|
|
status=JobStatus.RUNNING,
|
||
|
|
status_text="Performing pre-move checks...",
|
||
|
|
progress=5,
|
||
|
|
)
|
||
|
|
time.sleep(5)
|
||
|
|
Jobs.get_instance().update(
|
||
|
|
job=job,
|
||
|
|
status=JobStatus.RUNNING,
|
||
|
|
status_text="Performing pre-move checks...",
|
||
|
|
progress=10,
|
||
|
|
)
|
||
|
|
time.sleep(5)
|
||
|
|
Jobs.get_instance().update(
|
||
|
|
job=job,
|
||
|
|
status=JobStatus.RUNNING,
|
||
|
|
status_text="Performing pre-move checks...",
|
||
|
|
progress=15,
|
||
|
|
)
|
||
|
|
time.sleep(5)
|
||
|
|
Jobs.get_instance().update(
|
||
|
|
job=job,
|
||
|
|
status=JobStatus.RUNNING,
|
||
|
|
status_text="Performing pre-move checks...",
|
||
|
|
progress=20,
|
||
|
|
)
|
||
|
|
time.sleep(5)
|
||
|
|
Jobs.get_instance().update(
|
||
|
|
job=job,
|
||
|
|
status=JobStatus.RUNNING,
|
||
|
|
status_text="Performing pre-move checks...",
|
||
|
|
progress=25,
|
||
|
|
)
|
||
|
|
time.sleep(5)
|
||
|
|
Jobs.get_instance().update(
|
||
|
|
job=job,
|
||
|
|
status=JobStatus.FINISHED,
|
||
|
|
status_text="Job finished.",
|
||
|
|
progress=100,
|
||
|
|
)
|