style: pass ruff format

Author: GermanMT

src/dagster_app/assets/cargo_assets.py

@@ -30,9 +30,8 @@ def cargo_package_ingestion(
         cargo_svc = get_cargo_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()
@@ -126,9 +125,8 @@ def cargo_packages_updates(
         cargo_svc = get_cargo_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()

src/dagster_app/assets/maven_assets.py

@@ -30,9 +30,8 @@ def maven_package_ingestion(
         maven_svc = get_maven_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()
@@ -139,9 +138,8 @@ def maven_packages_updates(
         maven_svc = get_maven_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()

src/dagster_app/assets/npm_assets.py

@@ -30,9 +30,8 @@ def npm_package_ingestion(
         npm_svc = get_npm_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()
@@ -126,9 +125,8 @@ def npm_packages_updates(
         npm_svc = get_npm_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()

src/dagster_app/assets/nuget_assets.py

@@ -30,9 +30,8 @@ def nuget_package_ingestion(
         nuget_svc = get_nuget_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()
@@ -126,9 +125,8 @@ def nuget_packages_updates(
         nuget_svc = get_nuget_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()

src/dagster_app/assets/pypi_assets.py

@@ -30,9 +30,8 @@ def pypi_package_ingestion(
         pypi_svc = get_pypi_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()
@@ -124,9 +123,8 @@ def pypi_packages_updates(
         pypi_svc = get_pypi_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()

src/dagster_app/assets/redis_queue_assets.py

@@ -68,11 +68,9 @@ def redis_queue_processor(
         async def _process_messages():
             nonlocal total_processed, successful, failed, validation_errors, unsupported_types
 
-            # Initialize database connection
             db = get_db()
             await db.initialize()
 
-            # Get DB-dependent services after initialization
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()

src/dagster_app/assets/rubygems_assets.py

@@ -30,9 +30,8 @@ def rubygems_package_ingestion(
         rubygems_svc = get_rubygems_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()
@@ -126,9 +125,8 @@ def rubygems_packages_updates(
         rubygems_svc = get_rubygems_service()
 
         async def _run():
-            # Initialize database connection
             await get_db().initialize()
-            
+
             package_svc = get_package_service()
             version_svc = get_version_service()
             attr = get_attributor()