Automatic style fix for droidlet

droidlet/tools/crowdsourcing/sync_whitelists.py

@@ -25,15 +25,21 @@
 from droidlet.tools.crowdsourcing.droidlet_static_html_task.pilot_config import (
     PILOT_ALLOWLIST_QUAL_NAME as interaction_whitelist,
 )
-from droidlet.tools.crowdsourcing.droidlet_static_html_task.pilot_config import PILOT_BLOCK_QUAL_NAME as interaction_blacklist
-from droidlet.tools.crowdsourcing.droidlet_static_html_task.pilot_config import SOFTBLOCK_QUAL_NAME as interaction_softblock
+from droidlet.tools.crowdsourcing.droidlet_static_html_task.pilot_config import (
+    PILOT_BLOCK_QUAL_NAME as interaction_blacklist,
+)
+from droidlet.tools.crowdsourcing.droidlet_static_html_task.pilot_config import (
+    SOFTBLOCK_QUAL_NAME as interaction_softblock,
+)
 from droidlet.tools.crowdsourcing.vision_annotation_task.pilot_config import (
     PILOT_ALLOWLIST_QUAL_NAME as vision_annotation_whitelist,
 )
 from droidlet.tools.crowdsourcing.vision_annotation_task.pilot_config import (
     PILOT_BLOCK_QUAL_NAME as vision_annotation_blacklist,
 )
-from droidlet.tools.crowdsourcing.vision_annotation_task.pilot_config import SOFTBLOCK_QUAL_NAME as vision_softblock
+from droidlet.tools.crowdsourcing.vision_annotation_task.pilot_config import (
+    SOFTBLOCK_QUAL_NAME as vision_softblock,
+)
 
 qual_dict = {
     "interaction": {

droidlet/tools/hitl/dashboard_app/backend/dashboard_aws_helper.py

@@ -197,6 +197,7 @@ def get_model_by_id(batch_id: int):
     else:
         return load_model(local_fname), None
 
+
 def get_turk_list_by_pipeline(pipeline):
     output_dict_raw = import_s3_lists(S3_BUCKET_NAME_INTERNAL)
     qual_types = PIPELINE_QUAL_MAPPPING[pipeline]

droidlet/tools/hitl/dashboard_app/backend/dashboard_server.py

@@ -37,6 +37,7 @@ class DASHBOARD_EVENT(Enum):
     """
     server supported event types, i.e. API types
     """
+
     GET_RUNS = "get_job_list"
     GET_TRACEBACK = "get_traceback_by_id"
     GET_RUN_INFO = "get_run_info_by_id"
@@ -54,10 +55,11 @@ class DASHBOARD_EVENT(Enum):
     GET_MODEL_KEYS = "get_model_keys_by_id"
     GET_MODEL_VALUE = "get_model_value_by_id_n_key"
 
-    # apis for turk 
+    # apis for turk
     GET_TURK_LIST = "get_turk_list_by_pipeline"
     UPDATE_TURK = "update_turk_by_tid"
 
+
 # constants for model related apis
 KEY_COMPLETE = "complete_model"
 
@@ -232,24 +234,25 @@ def get_model_value(batch_id, key):
         # get a specific value
         emit(DASHBOARD_EVENT.GET_MODEL_VALUE.value, [key, get_value_by_key(model, key)])
 
+
 @socketio.on(DASHBOARD_EVENT.GET_TURK_LIST.value)
 def get_turk_list(pipeline: str):
     """
     get turk list for the corresponding pipeline
-    - input: 
-        - pipeline type 
+    - input:
+        - pipeline type
     - output:
         - a dict containing the turk allowlist, blocklist & softblock list
     """
-    print(
-        f"Request received: {DASHBOARD_EVENT.GET_TURK_LIST.value}, pipeline = {pipeline}"
-    )
+    print(f"Request received: {DASHBOARD_EVENT.GET_TURK_LIST.value}, pipeline = {pipeline}")
     out_dict = get_turk_list_by_pipeline(pipeline)
     emit(DASHBOARD_EVENT.GET_TURK_LIST.value, out_dict)
 
+
 @socketio.on(DASHBOARD_EVENT.UPDATE_TURK.value)
 def update_turk(pipeline, turk_id):
     pass
 
+
 if __name__ == "__main__":
     socketio.run(app)