| @@ -127,7 +127,7 @@ class EducationActivateLimitError(BaseHTTPException): | |||
| code = 429 | |||
| class CompilanceRateLimitError(BaseHTTPException): | |||
| error_code = "compilance_rate_limit" | |||
| class ComplianceRateLimitError(BaseHTTPException): | |||
| error_code = "compliance_rate_limit" | |||
| description = "Rate limit exceeded for downloading compliance report." | |||
| code = 429 | |||
| @@ -159,9 +159,9 @@ class BillingService: | |||
| ): | |||
| limiter_key = f"{account_id}:{tenant_id}" | |||
| if cls.compliance_download_rate_limiter.is_rate_limited(limiter_key): | |||
| from controllers.console.error import CompilanceRateLimitError | |||
| from controllers.console.error import ComplianceRateLimitError | |||
| raise CompilanceRateLimitError() | |||
| raise ComplianceRateLimitError() | |||
| json = { | |||
| "doc_name": doc_name, | |||
| @@ -422,7 +422,7 @@ class WorkflowDraftVariableService: | |||
| description=conv_var.description, | |||
| ) | |||
| draft_conv_vars.append(draft_var) | |||
| _batch_upsert_draft_varaible( | |||
| _batch_upsert_draft_variable( | |||
| self._session, | |||
| draft_conv_vars, | |||
| policy=_UpsertPolicy.IGNORE, | |||
| @@ -434,7 +434,7 @@ class _UpsertPolicy(StrEnum): | |||
| OVERWRITE = "overwrite" | |||
| def _batch_upsert_draft_varaible( | |||
| def _batch_upsert_draft_variable( | |||
| session: Session, | |||
| draft_vars: Sequence[WorkflowDraftVariable], | |||
| policy: _UpsertPolicy = _UpsertPolicy.OVERWRITE, | |||
| @@ -721,7 +721,7 @@ class DraftVariableSaver: | |||
| draft_vars = self._build_variables_from_start_mapping(outputs) | |||
| else: | |||
| draft_vars = self._build_variables_from_mapping(outputs) | |||
| _batch_upsert_draft_varaible(self._session, draft_vars) | |||
| _batch_upsert_draft_variable(self._session, draft_vars) | |||
| @staticmethod | |||
| def _should_variable_be_editable(node_id: str, name: str) -> bool: | |||
| @@ -444,9 +444,9 @@ class WorkflowService: | |||
| self, node_data: dict, tenant_id: str, user_id: str, node_id: str, user_inputs: dict[str, Any] | |||
| ) -> WorkflowNodeExecution: | |||
| """ | |||
| Run draft workflow node | |||
| Run free workflow node | |||
| """ | |||
| # run draft workflow node | |||
| # run free workflow node | |||
| start_at = time.perf_counter() | |||
| node_execution = self._handle_node_run_result( | |||