|
39 | 39 | logger = logging.getLogger(__package__) |
40 | 40 |
|
41 | 41 |
|
42 | | -# Engine sizes |
43 | | -@unique |
44 | | -class EngineSize(str, Enum): |
45 | | - XS = "XS" |
46 | | - S = "S" |
47 | | - M = "M" |
48 | | - L = "L" |
49 | | - XL = "XL" |
50 | | - |
51 | | - |
52 | 42 | # Database modes |
53 | 43 | @unique |
54 | 44 | class Mode(str, Enum): |
@@ -113,7 +103,6 @@ class Permission(str, Enum): |
113 | 103 |
|
114 | 104 | __all__ = [ |
115 | 105 | "Context", |
116 | | - "EngineSize", |
117 | 106 | "Mode", |
118 | 107 | "Role", |
119 | 108 | "Permission", |
@@ -371,14 +360,14 @@ def is_engine_term_state(state: str) -> bool: |
371 | 360 | return state == "PROVISIONED" or ("FAILED" in state) |
372 | 361 |
|
373 | 362 |
|
374 | | -def create_engine(ctx: Context, engine: str, size: EngineSize = EngineSize.XS, **kwargs): |
375 | | - data = {"region": ctx.region, "name": engine, "size": size.value} |
| 363 | +def create_engine(ctx: Context, engine: str, size: str = "XS", **kwargs): |
| 364 | + data = {"region": ctx.region, "name": engine, "size": size} |
376 | 365 | url = _mkurl(ctx, PATH_ENGINE) |
377 | 366 | rsp = rest.put(ctx, url, data, **kwargs) |
378 | 367 | return json.loads(rsp.read()) |
379 | 368 |
|
380 | 369 |
|
381 | | -def create_engine_wait(ctx: Context, engine: str, size: EngineSize = EngineSize.XS, **kwargs): |
| 370 | +def create_engine_wait(ctx: Context, engine: str, size: str = "XS", **kwargs): |
382 | 371 | create_engine(ctx, engine, size, **kwargs) |
383 | 372 | poll_with_specified_overhead( |
384 | 373 | lambda: is_engine_term_state(get_engine(ctx, engine)["state"]), |
|
0 commit comments