liniting again with black version 23.1.0

backend/functions/tasks.py

@@ -1614,4 +1614,4 @@ def upload_all_projects_to_blob_and_get_url(csv_files_directory):
         except Exception as e:
             return "Error in generating url"
         blob_url = f"https://{account_name}.blob.{endpoint_suffix}/{CONTAINER_NAME_FOR_DOWNLOAD_ALL_PROJECTS}/{blob_client.blob_name}?{sas_token}"
-    return blob_url
+    return blob_url

backend/notifications/migrations/0001_initial.py

@@ -5,7 +5,6 @@
 
 
 class Migration(migrations.Migration):
-
     initial = True
 
     dependencies = [

backend/organizations/tasks.py

@@ -1413,4 +1413,4 @@ def send_user_analytics_mail_org(
         [user.email],
         attachments=[(filename, content, content_type)],
     )
-    email.send()
+    email.send()

backend/organizations/views.py

@@ -2479,4 +2479,4 @@ def cumulative_tasks_count(self, request, pk=None):
                 pass
             else:
                 final_result_for_all_types[project_type] = final_result
-        return Response(final_result_for_all_types)
+        return Response(final_result_for_all_types)

backend/projects/views.py

@@ -637,9 +637,9 @@ def get_supercheck_reports(proj_id, userid, start_date, end_date):
         result["Rejected Word Count"] = rejected_word_count
     elif proj_type in get_audio_project_types():
         result["Validated Segments Duration"] = validated_audio_duration
-        result["Validated With Changes Segments Duration"] = (
-            validated_with_changes_audio_duration
-        )
+        result[
+            "Validated With Changes Segments Duration"
+        ] = validated_with_changes_audio_duration
         result["Rejected Segments Duration"] = rejected_audio_duration
         result["Total Raw Audio Duration"] = total_raw_audio_duration
         result["Average Word Error Rate R/S"] = round(avg_word_error_rate, 2)
@@ -3890,11 +3890,11 @@ def download(self, request, pk=None, *args, **kwargs):
                 if include_input_data_metadata_json:
                     dataset_type = project.dataset_id.all()[0].dataset_type
                     dataset_model = getattr(dataset_models, dataset_type)
-                    task_dict["data"]["input_data_metadata_json"] = (
-                        dataset_model.objects.get(
-                            pk=task_dict["input_data"]
-                        ).metadata_json
-                    )
+                    task_dict["data"][
+                        "input_data_metadata_json"
+                    ] = dataset_model.objects.get(
+                        pk=task_dict["input_data"]
+                    ).metadata_json
                 del task_dict["annotation_users"]
                 del task_dict["review_user"]
                 tasks_list.append(OrderedDict(task_dict))

backend/tasks/views.py

@@ -2235,4 +2235,4 @@ def get_celery_tasks(request):
     if "error" in filtered_tasks:
         return JsonResponse({"message": filtered_tasks["error"]}, status=503)
 
-    return JsonResponse(filtered_tasks, safe=False)
+    return JsonResponse(filtered_tasks, safe=False)

backend/users/migrations/0034_user_notification_limit.py

@@ -4,7 +4,6 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [
         ("users", "0033_auto_20240123_0310"),
     ]

backend/users/views.py

@@ -1559,4 +1559,4 @@ def fetch_language(self, request):
         )
         if serialized.is_valid():
             return Response(serialized.data, status=status.HTTP_200_OK)
-        return Response(serialized.errors, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+        return Response(serialized.errors, status=status.HTTP_500_INTERNAL_SERVER_ERROR)

backend/utils/search.py

@@ -80,4 +80,4 @@ def process_search_query(
     except Exception as e:
         print(f"\033[1mError found while processing query dictionary. In: {e}\033[0m")
 
-    return queryset_dict
+    return queryset_dict

backend/workspaces/migrations/0017_alter_workspace_guest_workspace.py

@@ -4,7 +4,6 @@
 
 
 class Migration(migrations.Migration):
-
     dependencies = [
         ("workspaces", "0016_workspace_workspace_password"),
     ]

backend/workspaces/tasks.py

@@ -2082,4 +2082,4 @@ def send_user_analysis_reports_mail_ws(
         celery_lock.releaseLock()
     except Exception as e:
         print(f"Error while releasing the lock for {task_name}: {str(e)}")
-    email.send()
+    email.send()