Skip to content

README.md

Latest commit

 

History

History
116 lines (81 loc) · 2.24 KB

README.md

File metadata and controls

116 lines (81 loc) · 2.24 KB
Raw

Schedule Management

Scheduler Client

Initialization

from conductor.client.configuration.configuration import Configuration
from conductor.shared.configuration.settings.authentication_settings import AuthenticationSettings
from conductor.client.orkes.orkes_scheduler_client import OrkesSchedulerClient

configuration = Configuration(
    server_api_url=SERVER_API_URL,
    debug=False,
    authentication_settings=AuthenticationSettings(key_id=KEY_ID, key_secret=KEY_SECRET)
)

scheduler_client = OrkesSchedulerClient(configuration)

Saving Schedule

from conductor.client.http.models import SaveScheduleRequest, StartWorkflowRequest

startWorkflowRequest = StartWorkflowRequest(
    name="WORKFLOW_NAME", workflow_def=workflowDef
)
saveScheduleRequest = SaveScheduleRequest(
    name="SCHEDULE_NAME",
    start_workflow_request=startWorkflowRequest,
    cron_expression="0 */5 * ? * *"
)

scheduler_client.save_schedule(saveScheduleRequest)

Get Schedule

Get a specific schedule

scheduler_client.get_schedule("SCHEDULE_NAME")

Get all schedules

scheduler_client.get_all_schedules()

Get all schedules for a workflow

scheduler_client.get_all_schedules("WORKFLOW_NAME")

Delete Schedule

scheduler_client.delete_schedule("SCHEDULE_NAME")

Pause and Resume Schedules

Pause a schedule

scheduler_client.pause_schedule("SCHEDULE_NAME")

Pause all schedules

scheduler_client.pause_all_schedules()

Resume a scheduler

scheduler_client.resume_schedule("SCHEDULE_NAME")

Resume all schedules

scheduler_client.resume_all_schedules()

Scheduler Tag Management

Set scheduler tags

from conductor.client.orkes.models.metadata_tag import MetadataTag

tags = [
    MetadataTag("sch_tag", "val"), MetadataTag("sch_tag_2", "val2")
]
scheduler_client.set_scheduler_tags(tags, "SCHEDULE_NAME")

Get scheduler tags

tags = scheduler_client.get_scheduler_tags("SCHEDULE_NAME")

Delete scheduler tags

tags = [
    MetadataTag("sch_tag", "val"), MetadataTag("sch_tag_2", "val2")
]
scheduler_client.delete_scheduler_tags(tags, "SCHEDULE_NAME")