|
1 | 1 | _schedule = import_module("/src/util/schedule.star")
|
2 | 2 |
|
3 | 3 |
|
4 |
| -def _default_launch(): |
| 4 | +def _default_launch(plan, dependencies): |
5 | 5 | return None
|
6 | 6 |
|
7 | 7 |
|
| 8 | +def test_util_schedule_dependency_invalid_item(plan): |
| 9 | + schedule = _schedule.create() |
| 10 | + |
| 11 | + # We check for a missing id |
| 12 | + expect.fails( |
| 13 | + lambda: schedule.add(struct()), |
| 14 | + "schedule: Expected an item to have a property 'id'", |
| 15 | + ) |
| 16 | + |
| 17 | + # We check for a mistyped id |
| 18 | + expect.fails( |
| 19 | + lambda: schedule.add(struct(id=123)), |
| 20 | + "schedule: Expected an item to have an 'id' of type string but 'id' is of type int", |
| 21 | + ) |
| 22 | + |
| 23 | + # We check for missing dependencies |
| 24 | + expect.fails( |
| 25 | + lambda: schedule.add(struct(id="a", launch=_default_launch)), |
| 26 | + "schedule: Expected an item to have a property 'dependencies'", |
| 27 | + ) |
| 28 | + |
| 29 | + # We check for mistyped dependencies |
| 30 | + expect.fails( |
| 31 | + lambda: schedule.add(struct(id="a", launch=_default_launch, dependencies="b")), |
| 32 | + "schedule: Expected an item to have a 'dependencies' property of type list but 'dependencies' is of type string", |
| 33 | + ) |
| 34 | + |
| 35 | + # We check for mistyped dependencies |
| 36 | + expect.fails( |
| 37 | + lambda: schedule.add( |
| 38 | + struct(id="a", launch=_default_launch, dependencies=[123, [], {}, False]) |
| 39 | + ), |
| 40 | + "schedule: Expected an item to have a 'dependencies' property of type list of strings but 'dependencies' contains 123 of type int, \\[\\] of type list, \\{\\} of type dict, False of type bool", |
| 41 | + ) |
| 42 | + |
| 43 | + # We check for missing launch |
| 44 | + expect.fails( |
| 45 | + lambda: schedule.add(struct(id="a", dependencies=["b"])), |
| 46 | + "schedule: Expected an item to have a property 'launch'", |
| 47 | + ) |
| 48 | + |
| 49 | + # We check for mistyped launch |
| 50 | + expect.fails( |
| 51 | + lambda: schedule.add(struct(id="a", launch=123, dependencies=["b"])), |
| 52 | + "schedule: Expected an item to have a 'launch' property of type function but 'launch' is of type int", |
| 53 | + ) |
| 54 | + |
| 55 | + |
8 | 56 | def test_util_schedule_dependency_on_self(plan):
|
9 | 57 | schedule = _schedule.create()
|
10 | 58 |
|
@@ -106,3 +154,100 @@ def test_util_schedule_simple_branching_dependencies(plan):
|
106 | 154 | schedule.sequence(),
|
107 | 155 | [item_b, item_c1, item_c3, item_c2, item_c21, item_a, item_c22, item_d],
|
108 | 156 | )
|
| 157 | + |
| 158 | + |
| 159 | +def test_util_schedule_launch_empty(plan): |
| 160 | + schedule = _schedule.create() |
| 161 | + |
| 162 | + # Launching an empty schedule should return an empty dict |
| 163 | + expect.eq(_schedule.launch(plan, schedule), {}) |
| 164 | + |
| 165 | + |
| 166 | +def test_util_schedule_launch_simple(plan): |
| 167 | + schedule = _schedule.create() |
| 168 | + |
| 169 | + schedule.add( |
| 170 | + _schedule.item( |
| 171 | + id="a", |
| 172 | + launch=lambda plan, dependencies: "a launched with dependencies {}".format( |
| 173 | + dependencies |
| 174 | + ), |
| 175 | + ) |
| 176 | + ) |
| 177 | + schedule.add( |
| 178 | + _schedule.item( |
| 179 | + id="b", |
| 180 | + launch=lambda plan, dependencies: "b launched with dependencies {}".format( |
| 181 | + dependencies |
| 182 | + ), |
| 183 | + dependencies=["a"], |
| 184 | + ) |
| 185 | + ) |
| 186 | + |
| 187 | + expect.eq( |
| 188 | + _schedule.launch(plan, schedule), |
| 189 | + { |
| 190 | + "a": "a launched with dependencies {}", |
| 191 | + "b": 'b launched with dependencies {"a": "a launched with dependencies {}"}', |
| 192 | + }, |
| 193 | + ) |
| 194 | + |
| 195 | + |
| 196 | +def test_util_schedule_launch_branching(plan): |
| 197 | + schedule = _schedule.create() |
| 198 | + |
| 199 | + schedule.add( |
| 200 | + _schedule.item( |
| 201 | + id="a", |
| 202 | + launch=lambda plan, dependencies: "a launched with dependencies {}".format( |
| 203 | + dependencies |
| 204 | + ), |
| 205 | + ) |
| 206 | + ) |
| 207 | + schedule.add( |
| 208 | + _schedule.item( |
| 209 | + id="b", |
| 210 | + launch=lambda plan, dependencies: "b launched with dependencies {}".format( |
| 211 | + dependencies |
| 212 | + ), |
| 213 | + dependencies=["a"], |
| 214 | + ) |
| 215 | + ) |
| 216 | + schedule.add( |
| 217 | + _schedule.item( |
| 218 | + id="c1", |
| 219 | + launch=lambda plan, dependencies: "c1 launched with dependencies {}".format( |
| 220 | + dependencies |
| 221 | + ), |
| 222 | + dependencies=["b"], |
| 223 | + ) |
| 224 | + ) |
| 225 | + schedule.add( |
| 226 | + _schedule.item( |
| 227 | + id="c2", |
| 228 | + launch=lambda plan, dependencies: "c2 launched with dependencies {}".format( |
| 229 | + dependencies |
| 230 | + ), |
| 231 | + dependencies=["b"], |
| 232 | + ) |
| 233 | + ) |
| 234 | + schedule.add( |
| 235 | + _schedule.item( |
| 236 | + id="d", |
| 237 | + launch=lambda plan, dependencies: "d launched with dependencies {}".format( |
| 238 | + dependencies |
| 239 | + ), |
| 240 | + dependencies=["c1", "c2"], |
| 241 | + ) |
| 242 | + ) |
| 243 | + |
| 244 | + expect.eq( |
| 245 | + _schedule.launch(plan, schedule), |
| 246 | + { |
| 247 | + "a": "a launched with dependencies {}", |
| 248 | + "b": 'b launched with dependencies {"a": "a launched with dependencies {}"}', |
| 249 | + "c1": 'c1 launched with dependencies {"a": "a launched with dependencies {}", "b": "b launched with dependencies {\\"a\\": \\"a launched with dependencies {}\\"}"}', |
| 250 | + "c2": 'c2 launched with dependencies {"a": "a launched with dependencies {}", "b": "b launched with dependencies {\\"a\\": \\"a launched with dependencies {}\\"}", "c1": "c1 launched with dependencies {\\"a\\": \\"a launched with dependencies {}\\", \\"b\\": \\"b launched with dependencies {\\\\\\"a\\\\\\": \\\\\\"a launched with dependencies {}\\\\\\"}\\"}"}', |
| 251 | + "d": 'd launched with dependencies {"a": "a launched with dependencies {}", "b": "b launched with dependencies {\\"a\\": \\"a launched with dependencies {}\\"}", "c1": "c1 launched with dependencies {\\"a\\": \\"a launched with dependencies {}\\", \\"b\\": \\"b launched with dependencies {\\\\\\"a\\\\\\": \\\\\\"a launched with dependencies {}\\\\\\"}\\"}", "c2": "c2 launched with dependencies {\\"a\\": \\"a launched with dependencies {}\\", \\"b\\": \\"b launched with dependencies {\\\\\\"a\\\\\\": \\\\\\"a launched with dependencies {}\\\\\\"}\\", \\"c1\\": \\"c1 launched with dependencies {\\\\\\"a\\\\\\": \\\\\\"a launched with dependencies {}\\\\\\", \\\\\\"b\\\\\\": \\\\\\"b launched with dependencies {\\\\\\\\\\\\\\"a\\\\\\\\\\\\\\": \\\\\\\\\\\\\\"a launched with dependencies {}\\\\\\\\\\\\\\"}\\\\\\"}\\"}"}', |
| 252 | + }, |
| 253 | + ) |
0 commit comments