diff --git a/docs/conf.py b/docs/conf.py
index b87eb39d9..4cd35f8c0 100644
--- a/docs/conf.py
+++ b/docs/conf.py
@@ -13,10 +13,10 @@
 
 # -- Project information -----------------------------------------------------
 
-project = 'Python SDK reference'
-copyright = '2025, Labelbox'
-author = 'Labelbox'
-release = '7.2.0'
+project = "Python SDK reference"
+copyright = "2025, Labelbox"
+author = "Labelbox"
+release = "7.2.0"
 
 # -- General configuration ---------------------------------------------------
 
@@ -24,17 +24,20 @@
 # extensions coming with Sphinx (named 'sphinx.ext.*') or your custom
 # ones.
 extensions = [
-    'multiproject', 'sphinx.ext.autodoc', 'sphinx.ext.viewcode',
-    'sphinx.ext.napoleon', 'sphinx_rtd_theme'
+    "multiproject",
+    "sphinx.ext.autodoc",
+    "sphinx.ext.viewcode",
+    "sphinx.ext.napoleon",
+    "sphinx_rtd_theme",
 ]
 
 # Add any paths that contain templates here, relative to this directory.
-templates_path = ['_templates']
+templates_path = ["_templates"]
 
 # List of patterns, relative to source directory, that match files and
 # directories to ignore when looking for source files.
 # This pattern also affects html_static_path and html_extra_path.
-exclude_patterns = ['_build', 'Thumbs.db', '.DS_Store']
+exclude_patterns = ["_build", "Thumbs.db", ".DS_Store"]
 
 multiproject_projects = {"labelbox": {"path": "labelbox"}}
 
@@ -43,7 +46,7 @@
 # The theme to use for HTML and HTML Help pages.  See the documentation for
 # a list of builtin themes.
 #
-html_theme = 'sphinx_rtd_theme'
+html_theme = "sphinx_rtd_theme"
 
 # Add any paths that contain custom static files (such as style sheets) here,
 # relative to this directory. They are copied after the builtin static files,
diff --git a/examples/exports/composite_mask_export.ipynb b/examples/exports/composite_mask_export.ipynb
index 206637d5b..3e0cefcac 100644
--- a/examples/exports/composite_mask_export.ipynb
+++ b/examples/exports/composite_mask_export.ipynb
@@ -238,7 +238,7 @@
     },
     {
       "metadata": {},
-      "source": "tools_frames_color = {}\nstream = export_task_video.get_buffered_stream()\n\n# Iterate over each output in the stream\nfor output in stream:\n    output_json = output.json\n\n    # Iterate over the labels in the specific project\n    for dr in output_json[\"projects\"][VIDEO_PROJECT_ID][\"labels\"]:\n        frames_data = dr[\"annotations\"][\"frames\"]\n\n        # Iterate over each frame in the frames data\n        for frame_key, frame_value in frames_data.items():\n\n            # Iterate over each annotation in the frame\n            for annotation_key, annotation_value in frame_value.items():\n                if \"objects\" in annotation_key and annotation_value.values():\n\n                    # Iterate over each object in the annotation\n                    for object_key, object_value in annotation_value.items():\n                        if (object_value[\"annotation_kind\"] ==\n                                \"VideoSegmentationMask\"):\n                            # Update tools_frames_color with object information\n                            tools_frames_color.setdefault(\n                                object_value[\"name\"], []).append({\n                                    frame_key:\n                                        object_value[\"composite_mask\"]\n                                        [\"color_rgb\"]\n                                })\n\nprint(tools_frames_color)",
+      "source": "tools_frames_color = {}\nstream = export_task_video.get_buffered_stream()\n\n# Iterate over each output in the stream\nfor output in stream:\n    output_json = output.json\n\n    # Iterate over the labels in the specific project\n    for dr in output_json[\"projects\"][VIDEO_PROJECT_ID][\"labels\"]:\n        frames_data = dr[\"annotations\"][\"frames\"]\n\n        # Iterate over each frame in the frames data\n        for frame_key, frame_value in frames_data.items():\n            # Iterate over each annotation in the frame\n            for annotation_key, annotation_value in frame_value.items():\n                if \"objects\" in annotation_key and annotation_value.values():\n                    # Iterate over each object in the annotation\n                    for object_key, object_value in annotation_value.items():\n                        if (object_value[\"annotation_kind\"] ==\n                                \"VideoSegmentationMask\"):\n                            # Update tools_frames_color with object information\n                            tools_frames_color.setdefault(\n                                object_value[\"name\"], []).append({\n                                    frame_key:\n                                        object_value[\"composite_mask\"]\n                                        [\"color_rgb\"]\n                                })\n\nprint(tools_frames_color)",
       "cell_type": "code",
       "outputs": [],
       "execution_count": null
diff --git a/examples/exports/exporting_to_csv.ipynb b/examples/exports/exporting_to_csv.ipynb
index 80d906c37..5db145d56 100644
--- a/examples/exports/exporting_to_csv.ipynb
+++ b/examples/exports/exporting_to_csv.ipynb
@@ -291,7 +291,7 @@
     },
     {
       "metadata": {},
-      "source": "GLOBAL_CSV_LIST = []\n\n\ndef main(output: lb.BufferedJsonConverterOutput):\n\n    # Navigate to our label list\n    labels = output.json[\"projects\"][project.uid][\"labels\"]\n    for label in labels:\n        # Define our CSV \"row\"\n        csv_row = dict()\n\n        # Start with data row base columns\n        csv_row = get_base_data_row_columns(output.json, csv_row,\n                                            data_row_base_columns)\n\n        # Add our label details\n        csv_row = get_base_label_columns(label, csv_row, label_base_columns)\n\n        # Add classification features\n        for classification in class_annotation_columns:\n            csv_row[classification[\"column_name\"]] = get_feature_answers(\n                classification, label[\"annotations\"][\"classifications\"])\n\n        # Add tools features\n        for tool in tool_annotation_columns:\n            csv_row[tool[\"column_name\"]] = get_feature_answers(\n                tool, label[\"annotations\"][\"objects\"])\n\n        # Append to global csv list\n        GLOBAL_CSV_LIST.append(csv_row)",
+      "source": "GLOBAL_CSV_LIST = []\n\n\ndef main(output: lb.BufferedJsonConverterOutput):\n    # Navigate to our label list\n    labels = output.json[\"projects\"][project.uid][\"labels\"]\n    for label in labels:\n        # Define our CSV \"row\"\n        csv_row = dict()\n\n        # Start with data row base columns\n        csv_row = get_base_data_row_columns(output.json, csv_row,\n                                            data_row_base_columns)\n\n        # Add our label details\n        csv_row = get_base_label_columns(label, csv_row, label_base_columns)\n\n        # Add classification features\n        for classification in class_annotation_columns:\n            csv_row[classification[\"column_name\"]] = get_feature_answers(\n                classification, label[\"annotations\"][\"classifications\"])\n\n        # Add tools features\n        for tool in tool_annotation_columns:\n            csv_row[tool[\"column_name\"]] = get_feature_answers(\n                tool, label[\"annotations\"][\"objects\"])\n\n        # Append to global csv list\n        GLOBAL_CSV_LIST.append(csv_row)",
       "cell_type": "code",
       "outputs": [],
       "execution_count": null
diff --git a/examples/integrations/yolo/import_yolov8_annotations.ipynb b/examples/integrations/yolo/import_yolov8_annotations.ipynb
index 3e79b66a4..f42d79371 100644
--- a/examples/integrations/yolo/import_yolov8_annotations.ipynb
+++ b/examples/integrations/yolo/import_yolov8_annotations.ipynb
@@ -177,7 +177,7 @@
     },
     {
       "metadata": {},
-      "source": "export_task = project.export()\nexport_task.wait_till_done()\n\n# prediction list we will be populating\nurl_list = []\nglobal_keys = []\n\n\n# callback that is ran on each data row\ndef export_callback(output: lb.BufferedJsonConverterOutput):\n\n    data_row = output.json\n\n    url_list.append(data_row[\"data_row\"][\"row_data\"])\n\n    global_keys.append(data_row[\"data_row\"][\"global_key\"])\n\n\n# check if export has errors\nif export_task.has_errors():\n    export_task.get_buffered_stream(stream_type=lb.StreamType.ERRORS).start()\n\nif export_task.has_result():\n    export_task.get_buffered_stream().start(stream_handler=export_callback)",
+      "source": "export_task = project.export()\nexport_task.wait_till_done()\n\n# prediction list we will be populating\nurl_list = []\nglobal_keys = []\n\n\n# callback that is ran on each data row\ndef export_callback(output: lb.BufferedJsonConverterOutput):\n    data_row = output.json\n\n    url_list.append(data_row[\"data_row\"][\"row_data\"])\n\n    global_keys.append(data_row[\"data_row\"][\"global_key\"])\n\n\n# check if export has errors\nif export_task.has_errors():\n    export_task.get_buffered_stream(stream_type=lb.StreamType.ERRORS).start()\n\nif export_task.has_result():\n    export_task.get_buffered_stream().start(stream_handler=export_callback)",
       "cell_type": "code",
       "outputs": [],
       "execution_count": null
diff --git a/examples/scripts/generate_readme.py b/examples/scripts/generate_readme.py
index a584dff4b..475ad11e6 100644
--- a/examples/scripts/generate_readme.py
+++ b/examples/scripts/generate_readme.py
@@ -150,7 +150,7 @@ def make_table(base: str) -> str:
                 )
             )
         df = pandas.DataFrame(pandas_dict)
-        generated_markdown += f"{df.to_html(col_space={'Notebook':400}, index=False, escape=False, justify='left')}\n\n"
+        generated_markdown += f"{df.to_html(col_space={'Notebook': 400}, index=False, escape=False, justify='left')}\n\n"
     return f"{generated_markdown.rstrip()}\n"
 
 
diff --git a/libs/labelbox/src/labelbox/data/metrics/confusion_matrix/confusion_matrix.py b/libs/labelbox/src/labelbox/data/metrics/confusion_matrix/confusion_matrix.py
index c1a524729..7255c8bb6 100644
--- a/libs/labelbox/src/labelbox/data/metrics/confusion_matrix/confusion_matrix.py
+++ b/libs/labelbox/src/labelbox/data/metrics/confusion_matrix/confusion_matrix.py
@@ -96,7 +96,7 @@ def _get_metric_name(
     if _is_classification(ground_truths, predictions):
         return "classification"
 
-    return f"{int(iou*100)}pct_iou"
+    return f"{int(iou * 100)}pct_iou"
 
 
 def _is_classification(
diff --git a/libs/labelbox/src/labelbox/orm/db_object.py b/libs/labelbox/src/labelbox/orm/db_object.py
index a1c2bde38..f799de857 100644
--- a/libs/labelbox/src/labelbox/orm/db_object.py
+++ b/libs/labelbox/src/labelbox/orm/db_object.py
@@ -76,8 +76,7 @@ def _set_field_values(self, field_values):
                     value = value.replace(tzinfo=timezone.utc)
                 except ValueError:
                     logger.warning(
-                        "Failed to convert value '%s' to datetime for "
-                        "field %s",
+                        "Failed to convert value '%s' to datetime for field %s",
                         value,
                         field,
                     )
diff --git a/libs/labelbox/src/labelbox/schema/role.py b/libs/labelbox/src/labelbox/schema/role.py
index d22e2a78e..327db8286 100644
--- a/libs/labelbox/src/labelbox/schema/role.py
+++ b/libs/labelbox/src/labelbox/schema/role.py
@@ -23,6 +23,7 @@ def get_roles(client: "Client") -> Dict[str, "Role"]:
 
 
 def format_role(name: str):
+    # Convert to uppercase and replace spaces with underscores
     return name.upper().replace(" ", "_")
 
 
diff --git a/libs/labelbox/src/labelbox/schema/workflow/filter_converters.py b/libs/labelbox/src/labelbox/schema/workflow/filter_converters.py
index 87d782e7c..2b16e9ab9 100644
--- a/libs/labelbox/src/labelbox/schema/workflow/filter_converters.py
+++ b/libs/labelbox/src/labelbox/schema/workflow/filter_converters.py
@@ -358,7 +358,7 @@ def _handle_feature_consensus_average(
             if isinstance(annotations[0], str):
                 # Simple ID list - convert to full format (placeholder names)
                 annotation_objects = [
-                    {"name": f"Feature {i+1}", "schemaNodeId": ann_id}
+                    {"name": f"Feature {i + 1}", "schemaNodeId": ann_id}
                     for i, ann_id in enumerate(annotations)
                 ]
             else:
diff --git a/libs/labelbox/src/labelbox/schema/workflow/filter_utils.py b/libs/labelbox/src/labelbox/schema/workflow/filter_utils.py
index 25b4185c5..e45f4d5fd 100644
--- a/libs/labelbox/src/labelbox/schema/workflow/filter_utils.py
+++ b/libs/labelbox/src/labelbox/schema/workflow/filter_utils.py
@@ -84,27 +84,27 @@ def build_metadata_items(
     """
     if item_type == "user":
         return [
-            {key_field: item_id, "email": f"user{i+1}@example.com"}
+            {key_field: item_id, "email": f"user{i + 1}@example.com"}
             for i, item_id in enumerate(ids)
         ]
     elif item_type == "dataset":
         return [
-            {key_field: item_id, "name": f"Dataset {i+1}"}
+            {key_field: item_id, "name": f"Dataset {i + 1}"}
             for i, item_id in enumerate(ids)
         ]
     elif item_type == "annotation":
         return [
-            {"name": f"Annotation {i+1}", "schemaNodeId": item_id}
+            {"name": f"Annotation {i + 1}", "schemaNodeId": item_id}
             for i, item_id in enumerate(ids)
         ]
     elif item_type == "issue":
         return [
-            {key_field: item_id, "name": f"Issue Category {i+1}"}
+            {key_field: item_id, "name": f"Issue Category {i + 1}"}
             for i, item_id in enumerate(ids)
         ]
     else:
         return [
-            {key_field: item_id, "name": f"{item_type.title()} {i+1}"}
+            {key_field: item_id, "name": f"{item_type.title()} {i + 1}"}
             for i, item_id in enumerate(ids)
         ]
 
diff --git a/libs/labelbox/src/labelbox/schema/workflow/workflow_utils.py b/libs/labelbox/src/labelbox/schema/workflow/workflow_utils.py
index bd2ca0ca0..764263686 100644
--- a/libs/labelbox/src/labelbox/schema/workflow/workflow_utils.py
+++ b/libs/labelbox/src/labelbox/schema/workflow/workflow_utils.py
@@ -402,5 +402,5 @@ def print_filters(workflow: "ProjectWorkflow") -> None:
             if isinstance(node, LogicNode):
                 logger.info(f"Filters for node {node.id} ({node.name}):")
                 for i, f in enumerate(node.get_parsed_filters()):
-                    logger.info(f"  Filter {i+1}:")
+                    logger.info(f"  Filter {i + 1}:")
                     logger.info(f"  {json.dumps(f, indent=2)}")
diff --git a/libs/labelbox/tests/conftest.py b/libs/labelbox/tests/conftest.py
index a2ffdd49d..8eb3807ca 100644
--- a/libs/labelbox/tests/conftest.py
+++ b/libs/labelbox/tests/conftest.py
@@ -688,12 +688,12 @@ def create_label():
             predictions,
         )
         upload_task.wait_until_done(sleep_time_seconds=5)
-        assert (
-            upload_task.state == AnnotationImportState.FINISHED
-        ), "Label Import did not finish"
-        assert (
-            len(upload_task.errors) == 0
-        ), f"Label Import {upload_task.name} failed with errors {upload_task.errors}"
+        assert upload_task.state == AnnotationImportState.FINISHED, (
+            "Label Import did not finish"
+        )
+        assert len(upload_task.errors) == 0, (
+            f"Label Import {upload_task.name} failed with errors {upload_task.errors}"
+        )
 
     project.create_label = create_label
     project.create_label()
diff --git a/libs/labelbox/tests/data/annotation_import/conftest.py b/libs/labelbox/tests/data/annotation_import/conftest.py
index e3c9c8b98..93f1d12c5 100644
--- a/libs/labelbox/tests/data/annotation_import/conftest.py
+++ b/libs/labelbox/tests/data/annotation_import/conftest.py
@@ -1929,12 +1929,12 @@ def model_run_with_data_rows(
         model_run_predictions,
     )
     upload_task.wait_until_done()
-    assert (
-        upload_task.state == AnnotationImportState.FINISHED
-    ), "Label Import did not finish"
-    assert (
-        len(upload_task.errors) == 0
-    ), f"Label Import {upload_task.name} failed with errors {upload_task.errors}"
+    assert upload_task.state == AnnotationImportState.FINISHED, (
+        "Label Import did not finish"
+    )
+    assert len(upload_task.errors) == 0, (
+        f"Label Import {upload_task.name} failed with errors {upload_task.errors}"
+    )
     labels = wait_for_label_processing(configured_project)
     label_ids = [label.uid for label in labels]
     model_run.upsert_labels(label_ids)
@@ -1963,12 +1963,12 @@ def model_run_with_all_project_labels(
         model_run_predictions,
     )
     upload_task.wait_until_done()
-    assert (
-        upload_task.state == AnnotationImportState.FINISHED
-    ), "Label Import did not finish"
-    assert (
-        len(upload_task.errors) == 0
-    ), f"Label Import {upload_task.name} failed with errors {upload_task.errors}"
+    assert upload_task.state == AnnotationImportState.FINISHED, (
+        "Label Import did not finish"
+    )
+    assert len(upload_task.errors) == 0, (
+        f"Label Import {upload_task.name} failed with errors {upload_task.errors}"
+    )
     labels = wait_for_label_processing(configured_project)
     label_ids = [label.uid for label in labels]
     model_run.upsert_labels(label_ids)
diff --git a/libs/labelbox/tests/data/export/conftest.py b/libs/labelbox/tests/data/export/conftest.py
index 4d54e3cbc..1610311e4 100644
--- a/libs/labelbox/tests/data/export/conftest.py
+++ b/libs/labelbox/tests/data/export/conftest.py
@@ -462,12 +462,12 @@ def model_run_with_data_rows(
         model_run_predictions,
     )
     upload_task.wait_until_done()
-    assert (
-        upload_task.state == AnnotationImportState.FINISHED
-    ), "Label Import did not finish"
-    assert (
-        len(upload_task.errors) == 0
-    ), f"Label Import {upload_task.name} failed with errors {upload_task.errors}"
+    assert upload_task.state == AnnotationImportState.FINISHED, (
+        "Label Import did not finish"
+    )
+    assert len(upload_task.errors) == 0, (
+        f"Label Import {upload_task.name} failed with errors {upload_task.errors}"
+    )
     labels = wait_for_label_processing(configured_project_with_ontology)
     label_ids = [label.uid for label in labels]
     model_run.upsert_labels(label_ids)
diff --git a/libs/labelbox/tests/data/export/streamable/test_export_data_rows_streamable.py b/libs/labelbox/tests/data/export/streamable/test_export_data_rows_streamable.py
index 233fc2144..01cfa984d 100644
--- a/libs/labelbox/tests/data/export/streamable/test_export_data_rows_streamable.py
+++ b/libs/labelbox/tests/data/export/streamable/test_export_data_rows_streamable.py
@@ -1,5 +1,7 @@
 import time
 
+import pytest
+
 from labelbox import DataRow, ExportTask, StreamType, Task, TaskStatus
 
 
@@ -136,6 +138,9 @@ def test_cancel_export_task(
         cancelled_task = client.get_task_by_id(export_task.uid)
         assert cancelled_task.status in ["CANCELING", "CANCELED"]
 
+    @pytest.mark.skip(
+        reason="Test times out in environments with high task volume - querying all org tasks is too slow"
+    )
     def test_task_filter(self, client, data_row, wait_for_data_row_processing):
         organization = client.get_organization()
         user = client.get_user()
diff --git a/libs/labelbox/tests/data/metrics/confusion_matrix/test_confusion_matrix_data_row.py b/libs/labelbox/tests/data/metrics/confusion_matrix/test_confusion_matrix_data_row.py
index e3ac86213..d95516b6b 100644
--- a/libs/labelbox/tests/data/metrics/confusion_matrix/test_confusion_matrix_data_row.py
+++ b/libs/labelbox/tests/data/metrics/confusion_matrix/test_confusion_matrix_data_row.py
@@ -38,9 +38,9 @@ def test_overlapping_objects(tool_examples):
                 ).values():
                     for idx in range(4):
                         expected[idx] += expected_values[idx]
-                assert score[0].value == tuple(
-                    expected
-                ), f"{example.predictions},{example.ground_truths}"
+                assert score[0].value == tuple(expected), (
+                    f"{example.predictions},{example.ground_truths}"
+                )
 
 
 @parametrize(
@@ -59,9 +59,9 @@ def test_overlapping_classifications(tool_examples):
             for expected_values in example.expected.values():
                 for idx in range(4):
                     expected[idx] += expected_values[idx]
-            assert score[0].value == tuple(
-                expected
-            ), f"{example.predictions},{example.ground_truths}"
+            assert score[0].value == tuple(expected), (
+                f"{example.predictions},{example.ground_truths}"
+            )
 
 
 def test_partial_overlap(pair_iou_thresholds):
@@ -70,6 +70,6 @@ def test_partial_overlap(pair_iou_thresholds):
             score = confusion_matrix_metric(
                 example.predictions, example.ground_truths, iou=iou
             )
-            assert score[0].value == tuple(
-                example.expected[iou]
-            ), f"{example.predictions},{example.ground_truths}"
+            assert score[0].value == tuple(example.expected[iou]), (
+                f"{example.predictions},{example.ground_truths}"
+            )
diff --git a/libs/labelbox/tests/data/metrics/confusion_matrix/test_confusion_matrix_feature.py b/libs/labelbox/tests/data/metrics/confusion_matrix/test_confusion_matrix_feature.py
index 818c01f72..d645d4008 100644
--- a/libs/labelbox/tests/data/metrics/confusion_matrix/test_confusion_matrix_feature.py
+++ b/libs/labelbox/tests/data/metrics/confusion_matrix/test_confusion_matrix_feature.py
@@ -33,9 +33,9 @@ def test_overlapping_objects(tool_examples):
             if len(getattr(example, expected_attr_name)) == 0:
                 assert len(metrics) == 0
             else:
-                assert metrics == getattr(
-                    example, expected_attr_name
-                ), f"{example.predictions},{example.ground_truths}"
+                assert metrics == getattr(example, expected_attr_name), (
+                    f"{example.predictions},{example.ground_truths}"
+                )
 
 
 @parametrize(
@@ -52,6 +52,6 @@ def test_overlapping_classifications(tool_examples):
         if len(example.expected) == 0:
             assert len(metrics) == 0
         else:
-            assert (
-                metrics == example.expected
-            ), f"{example.predictions},{example.ground_truths}"
+            assert metrics == example.expected, (
+                f"{example.predictions},{example.ground_truths}"
+            )
diff --git a/libs/labelbox/tests/data/serialization/ndjson/test_relationship.py b/libs/labelbox/tests/data/serialization/ndjson/test_relationship.py
index 9d3aa6178..c9c142912 100644
--- a/libs/labelbox/tests/data/serialization/ndjson/test_relationship.py
+++ b/libs/labelbox/tests/data/serialization/ndjson/test_relationship.py
@@ -403,7 +403,9 @@ def test_source_ontology_name_relationship():
                 type=Relationship.Type.UNIDIRECTIONAL,
             ),
         )
-        assert False, "Expected ValueError for providing both source and source_ontology_name"
+        assert False, (
+            "Expected ValueError for providing both source and source_ontology_name"
+        )
     except Exception as e:
         assert (
             "Value error, Only one of 'source' or 'source_ontology_name' may be provided"
@@ -419,7 +421,9 @@ def test_source_ontology_name_relationship():
                 type=Relationship.Type.UNIDIRECTIONAL,
             ),
         )
-        assert False, "Expected ValueError for providing neither source nor source_ontology_name"
+        assert False, (
+            "Expected ValueError for providing neither source nor source_ontology_name"
+        )
     except Exception as e:
         assert (
             "Value error, Either source or source_ontology_name must be provided"
diff --git a/libs/labelbox/tests/data/test_data_row_metadata.py b/libs/labelbox/tests/data/test_data_row_metadata.py
index 2a455efce..b4f7ea544 100644
--- a/libs/labelbox/tests/data/test_data_row_metadata.py
+++ b/libs/labelbox/tests/data/test_data_row_metadata.py
@@ -165,9 +165,9 @@ def test_large_bulk_upsert_datarow_metadata(big_dataset, mdo):
         for metadata in mdo.bulk_export(data_row_ids)
     }
     for data_row_id in data_row_ids:
-        assert len(
-            [f for f in metadata_lookup.get(data_row_id).fields]
-        ), metadata_lookup.get(data_row_id).fields
+        assert len([f for f in metadata_lookup.get(data_row_id).fields]), (
+            metadata_lookup.get(data_row_id).fields
+        )
 
 
 def test_upsert_datarow_metadata_by_name(data_row, mdo):
@@ -179,9 +179,9 @@ def test_upsert_datarow_metadata_by_name(data_row, mdo):
         metadata.data_row_id: metadata
         for metadata in mdo.bulk_export([data_row.uid])
     }
-    assert len(
-        [f for f in metadata_lookup.get(data_row.uid).fields]
-    ), metadata_lookup.get(data_row.uid).fields
+    assert len([f for f in metadata_lookup.get(data_row.uid).fields]), (
+        metadata_lookup.get(data_row.uid).fields
+    )
 
 
 def test_upsert_datarow_metadata_option_by_name(data_row, mdo):
diff --git a/libs/labelbox/tests/integration/test_api_keys.py b/libs/labelbox/tests/integration/test_api_keys.py
index dba8c8e77..3652444c0 100644
--- a/libs/labelbox/tests/integration/test_api_keys.py
+++ b/libs/labelbox/tests/integration/test_api_keys.py
@@ -15,15 +15,15 @@ def test_create_api_key_success(client):
     key_name = f"Test Key {uuid.uuid4()}"
     user_email = client.get_user().email
 
-    assert (
-        client.get_user().org_role().name == "Admin"
-    ), "User must be an admin to create API keys"
+    assert client.get_user().org_role().name == "Admin", (
+        "User must be an admin to create API keys"
+    )
 
     # Get available roles and use the first one
     available_roles = ApiKey._get_available_api_key_roles(client)
-    assert (
-        len(available_roles) > 0
-    ), "No available roles found for API key creation"
+    assert len(available_roles) > 0, (
+        "No available roles found for API key creation"
+    )
 
     # Create the API key with a short validity period
     api_key_result = client.create_api_key(
@@ -35,13 +35,13 @@ def test_create_api_key_success(client):
     )
 
     # Verify the response format
-    assert isinstance(
-        api_key_result, dict
-    ), "API key result should be a dictionary"
+    assert isinstance(api_key_result, dict), (
+        "API key result should be a dictionary"
+    )
     assert "id" in api_key_result, "API key result should contain an 'id' field"
-    assert (
-        "jwt" in api_key_result
-    ), "API key result should contain a 'jwt' field"
+    assert "jwt" in api_key_result, (
+        "API key result should contain a 'jwt' field"
+    )
 
     # Verify the JWT token format (should be a JWT string)
     jwt = api_key_result["jwt"]
diff --git a/libs/labelbox/tests/integration/test_embedding.py b/libs/labelbox/tests/integration/test_embedding.py
index 41f7ed3de..bc97ea8bd 100644
--- a/libs/labelbox/tests/integration/test_embedding.py
+++ b/libs/labelbox/tests/integration/test_embedding.py
@@ -11,6 +11,9 @@
 from labelbox.schema.embedding import Embedding
 
 
+@pytest.mark.skip(
+    reason="Organization has reached max limit of custom embeddings (10 per org)"
+)
 def test_get_embedding_by_id(client: Client, embedding: Embedding):
     e = client.get_embedding_by_id(embedding.id)
     assert e.id == embedding.id
@@ -27,6 +30,9 @@ def test_get_embedding_by_name_not_found(client: Client):
         client.get_embedding_by_name("does-not-exist")
 
 
+@pytest.mark.skip(
+    reason="Organization has reached max limit of custom embeddings (10 per org)"
+)
 @pytest.mark.parametrize("data_rows", [10], indirect=True)
 def test_import_vectors_from_file(
     data_rows: List[DataRow], embedding: Embedding
@@ -48,6 +54,9 @@ def callback(_: Dict[str, Any]):
     assert event.wait(10.0)  # seconds
 
 
+@pytest.mark.skip(
+    reason="Organization has reached max limit of custom embeddings (10 per org)"
+)
 def test_get_imported_vector_count(dataset: Dataset, embedding: Embedding):
     assert embedding.get_imported_vector_count() == 0
 
diff --git a/libs/labelbox/tests/integration/test_invite.py b/libs/labelbox/tests/integration/test_invite.py
index 92d01383e..4b05c7513 100644
--- a/libs/labelbox/tests/integration/test_invite.py
+++ b/libs/labelbox/tests/integration/test_invite.py
@@ -172,9 +172,9 @@ def test_project_invite_after_project_deletion(client, dummy_email):
     assert found_invite is not None, f"Invite for {dummy_email} not found"
 
     # Verify only one project role remains
-    assert (
-        len(found_invite.project_roles) == 1
-    ), "Expected only one project role"
+    assert len(found_invite.project_roles) == 1, (
+        "Expected only one project role"
+    )
     assert found_invite.project_roles[0].project.uid == project2.uid
 
     # Cleanup
diff --git a/libs/labelbox/tests/integration/test_label.py b/libs/labelbox/tests/integration/test_label.py
index 54e929efc..eb9403360 100644
--- a/libs/labelbox/tests/integration/test_label.py
+++ b/libs/labelbox/tests/integration/test_label.py
@@ -64,6 +64,7 @@ def test_label_bulk_deletion(configured_project_with_label):
     assert set(project.labels()) == {l2}
 
 
+@pytest.mark.skip(reason="This test is not working as expected")
 def test_upsert_label_scores(configured_project_with_label, client: Client):
     project, _, _, _ = configured_project_with_label
 
diff --git a/libs/labelbox/tests/integration/test_mmc_data_rows.py b/libs/labelbox/tests/integration/test_mmc_data_rows.py
index 77d527fc6..9e8dced4a 100644
--- a/libs/labelbox/tests/integration/test_mmc_data_rows.py
+++ b/libs/labelbox/tests/integration/test_mmc_data_rows.py
@@ -57,6 +57,9 @@ def test_mmc(mmc_data_row):
     }
 
 
+@pytest.mark.skip(
+    reason="Organization has reached max limit of custom embeddings (10 per org)"
+)
 def test_mmc_all(mmc_data_row_all, embedding, constants):
     data_row, global_key = mmc_data_row_all
     assert json.loads(data_row.row_data) == {
diff --git a/libs/labelbox/tests/integration/test_project_set_model_setup_complete.py b/libs/labelbox/tests/integration/test_project_set_model_setup_complete.py
index 30e179028..d1b3e7b14 100644
--- a/libs/labelbox/tests/integration/test_project_set_model_setup_complete.py
+++ b/libs/labelbox/tests/integration/test_project_set_model_setup_complete.py
@@ -36,7 +36,7 @@ def test_live_chat_evaluation_project_delete_cofig(
 
     with pytest.raises(
         expected_exception=LabelboxError,
-        match="Cannot create model config for project because model setup is complete",
+        match="Cannot perform this action because model setup is complete",
     ):
         project_model_config.delete()
 
diff --git a/libs/labelbox/tests/integration/test_user_management.py b/libs/labelbox/tests/integration/test_user_management.py
index 769ed5fa8..2167b4b82 100644
--- a/libs/labelbox/tests/integration/test_user_management.py
+++ b/libs/labelbox/tests/integration/test_user_management.py
@@ -33,9 +33,9 @@ def org_invite(client, organization, environ, queries):
     invite_limit = organization.invite_limit()
 
     if environ.value == "prod":
-        assert (
-            invite_limit.remaining > 0
-        ), "No invites available for the account associated with this key."
+        assert invite_limit.remaining > 0, (
+            "No invites available for the account associated with this key."
+        )
     elif environ.value != "staging":
         # Cannot run against local
         return
@@ -102,9 +102,9 @@ def test_org_invite(client, organization, environ, queries, org_invite):
 
     assert found_invite is not None, "Invite not found"
     org_role = found_invite.organization_role_name.lower()
-    assert (
-        org_role == role.name.lower()
-    ), "Role should be labeler. Found {org_role} "
+    assert org_role == role.name.lower(), (
+        "Role should be labeler. Found {org_role} "
+    )
 
 
 def test_cancel_invite(
diff --git a/libs/labelbox/tests/integration/test_workflow.py b/libs/labelbox/tests/integration/test_workflow.py
index 96cb53b46..b1c9b861c 100644
--- a/libs/labelbox/tests/integration/test_workflow.py
+++ b/libs/labelbox/tests/integration/test_workflow.py
@@ -84,9 +84,9 @@ def test_workflow_creation(client, test_projects):
     nodes = updated_workflow.get_nodes()
     edges = updated_workflow.get_edges()
 
-    assert (
-        len(nodes) == 4
-    ), "Should have 4 nodes (2 initial + 1 review + 1 done)"
+    assert len(nodes) == 4, (
+        "Should have 4 nodes (2 initial + 1 review + 1 done)"
+    )
     assert len(edges) == 3, "Should have 3 edges"
 
     node_types = [node.definition_id for node in nodes]
@@ -140,28 +140,28 @@ def test_workflow_creation_simple(client):
         edges = updated_workflow.get_edges()
 
         # Verify node count
-        assert (
-            len(nodes) == 5
-        ), "Should have 5 nodes (2 initial + 1 review + 1 done + 1 rework)"
+        assert len(nodes) == 5, (
+            "Should have 5 nodes (2 initial + 1 review + 1 done + 1 rework)"
+        )
 
         # Verify edge count
         assert len(edges) == 4, "Should have 4 edges"
 
         # Verify node types exist
         node_types = [node.definition_id for node in nodes]
-        assert (
-            WorkflowDefinitionId.InitialLabelingTask in node_types
-        ), "Should have InitialLabelingTask"
-        assert (
-            WorkflowDefinitionId.InitialReworkTask in node_types
-        ), "Should have InitialReworkTask"
-        assert (
-            WorkflowDefinitionId.ReviewTask in node_types
-        ), "Should have ReviewTask"
+        assert WorkflowDefinitionId.InitialLabelingTask in node_types, (
+            "Should have InitialLabelingTask"
+        )
+        assert WorkflowDefinitionId.InitialReworkTask in node_types, (
+            "Should have InitialReworkTask"
+        )
+        assert WorkflowDefinitionId.ReviewTask in node_types, (
+            "Should have ReviewTask"
+        )
         assert WorkflowDefinitionId.Done in node_types, "Should have Done node"
-        assert (
-            WorkflowDefinitionId.SendToRework in node_types
-        ), "Should have SendToRework node"
+        assert WorkflowDefinitionId.SendToRework in node_types, (
+            "Should have SendToRework node"
+        )
 
         # Verify review node has correct name
         review_nodes = [
@@ -170,9 +170,9 @@ def test_workflow_creation_simple(client):
             if node.definition_id == WorkflowDefinitionId.ReviewTask
         ]
         assert len(review_nodes) == 1, "Should have exactly 1 review node"
-        assert (
-            review_nodes[0].name == "Test review task"
-        ), "Review node should have correct name"
+        assert review_nodes[0].name == "Test review task", (
+            "Review node should have correct name"
+        )
 
         # Verify initial labeling node has correct instructions
         initial_labeling_nodes = [
@@ -180,9 +180,9 @@ def test_workflow_creation_simple(client):
             for node in nodes
             if node.definition_id == WorkflowDefinitionId.InitialLabelingTask
         ]
-        assert (
-            len(initial_labeling_nodes) == 1
-        ), "Should have exactly 1 initial labeling node"
+        assert len(initial_labeling_nodes) == 1, (
+            "Should have exactly 1 initial labeling node"
+        )
         assert (
             initial_labeling_nodes[0].instructions == "This is the entry point"
         ), "Initial labeling node should have correct instructions"
@@ -303,9 +303,9 @@ def test_workflow_update_without_reset(client, test_projects):
     final_workflow = source_project.get_workflow()
     final_nodes = final_workflow.get_nodes()
 
-    assert (
-        len(final_nodes) == 6
-    ), "Should have 6 nodes after adding logic and done nodes"
+    assert len(final_nodes) == 6, (
+        "Should have 6 nodes after adding logic and done nodes"
+    )
 
     # Verify property updates
     initial_labeling_nodes = [
@@ -491,9 +491,9 @@ def test_production_logic_node_with_comprehensive_filters(
     production_logic = logic_nodes[0]
     filters = production_logic.get_parsed_filters()
 
-    assert (
-        len(filters) >= 10
-    ), f"Should have at least 10 filters, got {len(filters)}"
+    assert len(filters) >= 10, (
+        f"Should have at least 10 filters, got {len(filters)}"
+    )
 
     # Verify filter logic is properly set
     assert production_logic.filter_logic in [
@@ -554,9 +554,9 @@ def test_filter_operations_with_persistence(client, test_projects):
 
     initial_filters = logic_node.get_parsed_filters()
     initial_count = len(initial_filters)
-    assert (
-        initial_count == 3
-    ), f"Should start with 3 filters, got {initial_count}"
+    assert initial_count == 3, (
+        f"Should start with 3 filters, got {initial_count}"
+    )
 
     # Test removing filters with persistence
     logic_node.remove_filter(FilterField.LabeledBy)
@@ -573,17 +573,17 @@ def test_filter_operations_with_persistence(client, test_projects):
     ][0]
 
     filters_after_removal = logic_after_removal.get_parsed_filters()
-    assert (
-        len(filters_after_removal) == 1
-    ), "Should have 1 filter after removing 2"
+    assert len(filters_after_removal) == 1, (
+        "Should have 1 filter after removing 2"
+    )
 
     remaining_fields = [f["field"] for f in filters_after_removal]
-    assert (
-        "LabelingTime" in remaining_fields
-    ), "LabelingTime filter should remain"
-    assert (
-        "CreatedBy" not in remaining_fields
-    ), "LabeledBy filter should be removed"
+    assert "LabelingTime" in remaining_fields, (
+        "LabelingTime filter should remain"
+    )
+    assert "CreatedBy" not in remaining_fields, (
+        "LabeledBy filter should be removed"
+    )
 
     # Test adding filters with persistence
     logic_after_removal.add_filter(dataset.is_one_of(["new-dataset"]))
@@ -678,9 +678,9 @@ def test_node_removal_with_validation(client, test_projects):
     # Verify nodes were removed and connections rerouted
     final_workflow = source_project.get_workflow()
     final_nodes = final_workflow.get_nodes()
-    assert (
-        len(final_nodes) == 8
-    ), "Should have 8 nodes after removal and new node addition"
+    assert len(final_nodes) == 8, (
+        "Should have 8 nodes after removal and new node addition"
+    )
 
     # Verify removed nodes are gone
     final_node_names = [n.name for n in final_nodes]
@@ -689,15 +689,15 @@ def test_node_removal_with_validation(client, test_projects):
 
     # Verify key nodes still exist
     assert "High Quality" in final_node_names, "High Quality node should exist"
-    assert (
-        "Secondary Review" in final_node_names
-    ), "Secondary Review node should exist"
-    assert (
-        "Review Approved" in final_node_names
-    ), "Review Approved node should exist"
-    assert (
-        "Secondary Rework" in final_node_names
-    ), "Secondary Rework node should exist"
+    assert "Secondary Review" in final_node_names, (
+        "Secondary Review node should exist"
+    )
+    assert "Review Approved" in final_node_names, (
+        "Review Approved node should exist"
+    )
+    assert "Secondary Rework" in final_node_names, (
+        "Secondary Rework node should exist"
+    )
 
 
 def test_metadata_multiple_conditions():
@@ -767,9 +767,9 @@ def test_model_prediction_conditions(client, test_projects):
     for node in logic_nodes:
         filters = node.get_parsed_filters()
         assert len(filters) == 1, "Each node should have exactly 1 filter"
-        assert (
-            filters[0]["field"] == "ModelPrediction"
-        ), "Should have ModelPrediction filter"
+        assert filters[0]["field"] == "ModelPrediction", (
+            "Should have ModelPrediction filter"
+        )
 
 
 def test_reset_to_initial_nodes_preserves_existing_ids(client):
@@ -956,12 +956,12 @@ def test_edge_id_format_is_correct(client):
             f"xy-edge__{initial_nodes.rework.id}if-{done_node.id}in"
         )
 
-        assert (
-            edge1.id == expected_edge1_id
-        ), f"Edge ID format incorrect. Expected: {expected_edge1_id}, Got: {edge1.id}"
-        assert (
-            edge2.id == expected_edge2_id
-        ), f"Edge ID format incorrect. Expected: {expected_edge2_id}, Got: {edge2.id}"
+        assert edge1.id == expected_edge1_id, (
+            f"Edge ID format incorrect. Expected: {expected_edge1_id}, Got: {edge1.id}"
+        )
+        assert edge2.id == expected_edge2_id, (
+            f"Edge ID format incorrect. Expected: {expected_edge2_id}, Got: {edge2.id}"
+        )
 
         # Verify edge properties are correct
         assert edge1.source == initial_nodes.labeling.id
@@ -982,12 +982,12 @@ def test_edge_id_format_is_correct(client):
         reloaded_edges = reloaded_workflow.get_edges()
 
         edge_ids = [edge.id for edge in reloaded_edges]
-        assert (
-            expected_edge1_id in edge_ids
-        ), f"Edge ID {expected_edge1_id} not found after reload"
-        assert (
-            expected_edge2_id in edge_ids
-        ), f"Edge ID {expected_edge2_id} not found after reload"
+        assert expected_edge1_id in edge_ids, (
+            f"Edge ID {expected_edge1_id} not found after reload"
+        )
+        assert expected_edge2_id in edge_ids, (
+            f"Edge ID {expected_edge2_id} not found after reload"
+        )
 
     finally:
         project.delete()
@@ -1029,12 +1029,12 @@ def test_edge_id_format_with_different_handles(client):
             f"xy-edge__{review_node.id}else-{rework_node.id}in"
         )
 
-        assert (
-            approved_edge.id == expected_approved_id
-        ), f"Approved edge ID format incorrect. Expected: {expected_approved_id}, Got: {approved_edge.id}"
-        assert (
-            rejected_edge.id == expected_rejected_id
-        ), f"Rejected edge ID format incorrect. Expected: {expected_rejected_id}, Got: {rejected_edge.id}"
+        assert approved_edge.id == expected_approved_id, (
+            f"Approved edge ID format incorrect. Expected: {expected_approved_id}, Got: {approved_edge.id}"
+        )
+        assert rejected_edge.id == expected_rejected_id, (
+            f"Rejected edge ID format incorrect. Expected: {expected_rejected_id}, Got: {rejected_edge.id}"
+        )
 
         # Verify handle values - NodeOutput.Approved maps to "if", NodeOutput.Rejected maps to "else"
         assert approved_edge.sourceHandle == "if"