summaryrefslogtreecommitdiff
path: root/jb/managers/worker.py
diff options
context:
space:
mode:
authorMax Nanis2026-02-19 02:43:23 -0500
committerMax Nanis2026-02-19 02:43:23 -0500
commitf0f96f83c2630e890a2cbcab53f77fd4c37e1684 (patch)
treec6d2cb092e76bf5d499e0ea9949508d6b22164fd /jb/managers/worker.py
parent3eaa56f0306ead818f64c3d99fc6d230d9b970a4 (diff)
downloadamt-jb-f0f96f83c2630e890a2cbcab53f77fd4c37e1684.tar.gz
amt-jb-f0f96f83c2630e890a2cbcab53f77fd4c37e1684.zip
Models, Project files, some pytests, requirements.. etcHEADmaster
Diffstat (limited to 'jb/managers/worker.py')
-rw-r--r--jb/managers/worker.py16
1 files changed, 16 insertions, 0 deletions
diff --git a/jb/managers/worker.py b/jb/managers/worker.py
new file mode 100644
index 0000000..e2d7237
--- /dev/null
+++ b/jb/managers/worker.py
@@ -0,0 +1,16 @@
+from typing import List
+
+from mypy_boto3_mturk.type_defs import WorkerBlockTypeDef
+
+from jb.decorators import AMT_CLIENT
+
+
+class WorkerManager:
+
+ @staticmethod
+ def fetch_worker_blocks() -> List[WorkerBlockTypeDef]:
+ p = AMT_CLIENT.get_paginator("list_worker_blocks")
+ res: List[WorkerBlockTypeDef] = []
+ for item in p.paginate():
+ res.extend(item["WorkerBlocks"])
+ return res