linters

fixbackend/cloud_accounts/azure_subscription_repo.py

@@ -120,11 +120,15 @@ async def get_by_tenant(self, tenant_id: WorkspaceId) -> Optional[AzureSubscript
 
             return entity.to_model()
 
-    async def list_created_after(self, time: datetime, can_access_azure_account: Optional[bool] = None) -> List[AzureSubscriptionCredentials]:
+    async def list_created_after(
+        self, time: datetime, can_access_azure_account: Optional[bool] = None
+    ) -> List[AzureSubscriptionCredentials]:
         async with self._session_maker() as session:
             filters = [AzureSubscriptionCredentialsEntity.created_at > time]
             if can_access_azure_account is not None:
-                filters.append(AzureSubscriptionCredentialsEntity.can_access_azure_account.is_(can_access_azure_account))
+                filters.append(
+                    AzureSubscriptionCredentialsEntity.can_access_azure_account.is_(can_access_azure_account)
+                )
             query = select(AzureSubscriptionCredentialsEntity).filter(*filters)
             result = await session.execute(query)
             return [entity.to_model() for entity in result.scalars()]

fixbackend/cloud_accounts/azure_subscription_service.py

@@ -139,8 +139,7 @@ async def _import_subscriptions(self, creds: AzureSubscriptionCredentials) -> No
 
     async def _ping_new_subscriptions(self) -> None:
         created_less_than_30_minutes_ago = await self.azure_subscriptions_repo.list_created_after(
-            utc() - timedelta(minutes=30),
-            can_access_azure_account=False
+            utc() - timedelta(minutes=30), can_access_azure_account=False
         )
 
         async with asyncio.TaskGroup() as tg: