-
Notifications
You must be signed in to change notification settings - Fork 0
/
dynamo_db.py
49 lines (40 loc) · 1.21 KB
/
dynamo_db.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
# DynamoDB table indices
DEVICE_ID = "DeviceId"
GOAL_DIST = "GoalDist"
LOCAL_DIST = "LocalDist"
DATA_INDICES = "DataIndices"
MODEL_INFO = "ModelInfo"
TIMESTAMPS = "TimeStamps"
EVAL_HIST_LOSS = "EvalHistLoss"
EVAL_HIST_METRIC = "EvalHistMetric"
ENC_IDX = "EncIdx"
HOSTNAME = "Hostname"
TOTAL_ENC_IDX = "TotalEncIdx"
ORIG_ENC_IDX = "OrigEncIdx"
WC_TIMESTAMPS = "WCTimeStamps"
ENCOUNTER_HISTORY = "EncounterHistory"
DEV_STATUS = "DeviceStatus"
ERROR_TRACE = "ErrorTrace"
# Overmind worker state DB
WORKER_ID = "WorkerId"
WORKER_STATUS = "WorkerStatus"
WORKER_HISTORY = "WorkerHistory"
# TaskHistory keys
WTIMESTAMP = "TimeStamp"
ACTION_TYPE = "ActionType"
TASK_DETAILS = "TaskDetails"
ERROR_MSG = "ErrorMsg"
# Action Types
WORKER_CREATED = "WorkerCreated"
WORKER_ADDED = "WorkerAdded" # worker added to a swarm
TASK_START = "TaskStart"
TASK_FAILED = "TaskFailed"
TASK_TIMEOUT = "TaskTimeout"
TASK_END = "TaskEnd"
TASK_REALTIME_TIMEOUT = "TaskRealTimeTimeout" # timeout in real-time mode
# Done-tasks table
TASK_ID = "TaskId"
IS_FINISHED = "IsFinished"
IS_PROCESSED = "IsProcessed" # is it processed by overmind controller
IS_TIMED_OUT = "IsTimedOut" # timed out in swarm context. the encounter was not long enough
TIME = "Time"