-
Notifications
You must be signed in to change notification settings - Fork 0
/
populate.py
170 lines (121 loc) · 5.98 KB
/
populate.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
#!/usr/bin/env python
# -*- coding: utf-8 -*-
# This file has been automatically generated, changes may be lost if you
# go and generate it again. It was generated with the following command:
# ./manage.py dumpscript core scheduler jobrunner
import datetime
from decimal import Decimal
from django.contrib.contenttypes.models import ContentType
def run():
from chronix.core.models import Application
core_application_1 = Application()
core_application_1.name = u'test application'
core_application_1.save()
from chronix.core.models import Condition
from chronix.core.models import TimeCondition
from chronix.core.models import FlowCondition
from chronix.core.models import ExclusionCondition
from chronix.core.models import OrCondition
from chronix.core.models import Activity
core_activity_1 = Activity()
core_activity_1.name = u'begin activity'
core_activity_1.save()
core_activity_2 = Activity()
core_activity_2.name = u'end activity'
core_activity_2.save()
from chronix.core.models import ShellActivity
from chronix.core.models import WebServiceActivity
from chronix.core.models import StoredProcedureActivity
from chronix.core.models import Chain
core_chain_1 = Chain()
core_chain_1.name = u'test chain'
core_chain_1.application = core_application_1
core_chain_1.start_activity = core_activity_1
core_chain_1.end_activity = core_activity_2
core_chain_1.save()
from chronix.core.models import Recurrence
core_recurrence_1 = Recurrence()
core_recurrence_1.name = u'every 10 sec'
core_recurrence_1.frequency = 6
core_recurrence_1.start_date = datetime.datetime(2009, 1, 18, 20, 11, 17)
core_recurrence_1.params = u'{"interval":10}'
core_recurrence_1.save()
from chronix.core.models import TaskProfile
core_taskprofile_1 = TaskProfile()
core_taskprofile_1.name = u'test profile'
core_taskprofile_1.recurrence = core_recurrence_1
core_taskprofile_1.stop_if_last_run_failed = True
core_taskprofile_1.forgot_misfire = True
core_taskprofile_1.save()
from chronix.core.models import Task
core_task_1 = Task()
core_task_1.name = u'test task'
core_task_1.chain = core_chain_1
core_task_1.profile = core_taskprofile_1
core_task_1.disable = False
core_task_1.next_run = datetime.datetime(2009, 1, 25, 14, 57, 17)
core_task_1.last_run = datetime.datetime(2009, 1, 25, 14, 57, 7)
core_task_1.last_run_failed = False
core_task_1.save()
from chronix.scheduler.models import TaskSchedulerNode
scheduler_taskschedulernode_1 = TaskSchedulerNode()
scheduler_taskschedulernode_1.name = u'test'
scheduler_taskschedulernode_1.start_date = datetime.datetime(2009, 1, 25, 14, 57, 0, 387580)
scheduler_taskschedulernode_1.state = u'STOPPED'
scheduler_taskschedulernode_1.save()
scheduler_taskschedulernode_1.tasks.add(core_task_1)
from chronix.scheduler.models import LaunchedTask
scheduler_launchedtask_1 = LaunchedTask()
scheduler_launchedtask_1.planned_launch_date = datetime.datetime(2009, 1, 18, 20, 20, 7)
scheduler_launchedtask_1.real_launch_date = datetime.datetime(2009, 1, 25, 14, 57, 0, 430451)
scheduler_launchedtask_1.update_date = datetime.datetime(2009, 1, 25, 14, 57, 0, 435468)
scheduler_launchedtask_1.current_activity = None
scheduler_launchedtask_1.state = u'FIRED'
scheduler_launchedtask_1.task = core_task_1
scheduler_launchedtask_1.save()
scheduler_launchedtask_2 = LaunchedTask()
scheduler_launchedtask_2.planned_launch_date = datetime.datetime(2009, 1, 25, 14, 56, 57)
scheduler_launchedtask_2.real_launch_date = datetime.datetime(2009, 1, 25, 14, 57, 3, 950013)
scheduler_launchedtask_2.update_date = datetime.datetime(2009, 1, 25, 14, 57, 3, 953007)
scheduler_launchedtask_2.current_activity = None
scheduler_launchedtask_2.state = u'FIRED'
scheduler_launchedtask_2.task = core_task_1
scheduler_launchedtask_2.save()
scheduler_launchedtask_3 = LaunchedTask()
scheduler_launchedtask_3.planned_launch_date = datetime.datetime(2009, 1, 25, 14, 57, 7)
scheduler_launchedtask_3.real_launch_date = datetime.datetime(2009, 1, 25, 14, 57, 11, 445970)
scheduler_launchedtask_3.update_date = datetime.datetime(2009, 1, 25, 14, 57, 11, 455063)
scheduler_launchedtask_3.current_activity = None
scheduler_launchedtask_3.state = u'FIRED'
scheduler_launchedtask_3.task = core_task_1
scheduler_launchedtask_3.save()
from chronix.scheduler.models import TaskEvent
from chronix.jobrunner.models import JobRunnerNode
jobrunner_jobrunnernode_1 = JobRunnerNode()
jobrunner_jobrunnernode_1.name = u'test'
jobrunner_jobrunnernode_1.max_runner = 20
jobrunner_jobrunnernode_1.save()
from chronix.jobrunner.models import JobQueueAlgorithm
jobrunner_jobqueuealgorithm_1 = JobQueueAlgorithm()
jobrunner_jobqueuealgorithm_1.name = u'fifo'
jobrunner_jobqueuealgorithm_1.class_name = u'FifoJobQueue'
jobrunner_jobqueuealgorithm_1.save()
jobrunner_jobqueuealgorithm_2 = JobQueueAlgorithm()
jobrunner_jobqueuealgorithm_2.name = u'random'
jobrunner_jobqueuealgorithm_2.class_name = u'RandomJobQueue'
jobrunner_jobqueuealgorithm_2.save()
from chronix.jobrunner.models import JobQueueConfig
jobrunner_jobqueueconfig_1 = JobQueueConfig()
jobrunner_jobqueueconfig_1.name = u'toto'
jobrunner_jobqueueconfig_1.max_runner = 10
jobrunner_jobqueueconfig_1.node = jobrunner_jobrunnernode_1
jobrunner_jobqueueconfig_1.algorithm = jobrunner_jobqueuealgorithm_2
jobrunner_jobqueueconfig_1.param = u''
jobrunner_jobqueueconfig_1.save()
jobrunner_jobqueueconfig_2 = JobQueueConfig()
jobrunner_jobqueueconfig_2.name = u'lala'
jobrunner_jobqueueconfig_2.max_runner = 15
jobrunner_jobqueueconfig_2.node = jobrunner_jobrunnernode_1
jobrunner_jobqueueconfig_2.algorithm = jobrunner_jobqueuealgorithm_1
jobrunner_jobqueueconfig_2.param = u''
jobrunner_jobqueueconfig_2.save()