🪓 An orchestration engine for background tasks, AI agents, and durable workflows
This report summarizes scanner evidence for hatchet-dev/hatchet, a Go project with 8,097 GitHub stars. SynthScan examined 875,264 lines of code across 4347 source files, recording 4825 pattern matches distributed across 24 syntactic categories. The legacy adjusted pattern signal is 10.5 (Moderate pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 2197 finding(s).
Are imports declared and package/API names verified? 1423 finding(s).
Are wrappers, guards, and repeated structures necessary? 2576 finding(s).
Which changes need focused human review? 4825 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 4825 distinct pattern matches across 24 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | sdks/python/hatchet_sdk/clients/rest/configuration.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | sdks/python/hatchet_sdk/clients/rest/rest.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | sdks/python/hatchet_sdk/clients/rest/__init__.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | sdks/python/hatchet_sdk/clients/rest/exceptions.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | sdks/python/hatchet_sdk/clients/rest/api_client.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …ks/python/hatchet_sdk/clients/rest/models/v1_filter.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …/hatchet_sdk/clients/rest/models/v1_task_event_list.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …et_sdk/clients/rest/models/list_api_tokens_response.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …het_sdk/clients/rest/models/workflow_update_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …ks/python/hatchet_sdk/clients/rest/models/otel_span.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …thon/hatchet_sdk/clients/rest/models/step_run_event.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …tchet_sdk/clients/rest/models/tenant_resource_limit.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …tchet_sdk/clients/rest/models/update_worker_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | sdks/python/hatchet_sdk/clients/rest/models/worker.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …/hatchet_sdk/clients/rest/models/pull_request_state.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …ython/hatchet_sdk/clients/rest/models/queue_metrics.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …dk/clients/rest/models/info_get_version200_response.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …tchet_sdk/clients/rest/models/accept_invite_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …et_sdk/clients/rest/models/v1_create_filter_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …ython/hatchet_sdk/clients/rest/models/api_meta_auth.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …atchet_sdk/clients/rest/models/replay_event_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …chet_sdk/clients/rest/models/pause_workflow_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | sdks/python/hatchet_sdk/clients/rest/models/user.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …dk/clients/rest/models/update_tenant_invite_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …s/python/hatchet_sdk/clients/rest/models/event_list.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …python/hatchet_sdk/clients/rest/models/v1_wait_item.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …tchet_sdk/clients/rest/models/v1_task_point_metrics.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …atchet_sdk/clients/rest/models/v1_cel_debug_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …t_sdk/clients/rest/models/rate_limit_order_by_field.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …on/hatchet_sdk/clients/rest/models/recent_step_runs.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …python/hatchet_sdk/clients/rest/models/pull_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …/hatchet_sdk/clients/rest/models/v1_cancelled_tasks.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …ython/hatchet_sdk/clients/rest/models/step_run_diff.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | sdks/python/hatchet_sdk/clients/rest/models/event.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …et_sdk/clients/rest/models/create_api_token_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …tchet_sdk/clients/rest/models/step_run_archive_list.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …tchet_sdk/clients/rest/models/v1_logs_point_metrics.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …clients/rest/models/v1_branch_durable_task_response.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …t_sdk/clients/rest/models/create_api_token_response.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …k/clients/rest/models/webhook_worker_request_method.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …/hatchet_sdk/clients/rest/models/v1_task_run_status.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …thon/hatchet_sdk/clients/rest/models/log_line_level.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …/hatchet_sdk/clients/rest/models/tenant_member_list.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …/clients/rest/models/pause_workflow_request_unpause.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …on/hatchet_sdk/clients/rest/models/v1_workflow_type.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …hatchet_sdk/clients/rest/models/pagination_response.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …het_sdk/clients/rest/models/v1_webhook_api_key_auth.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …hon/hatchet_sdk/clients/rest/models/step_run_status.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | sdks/python/hatchet_sdk/clients/rest/models/tenant.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …et_sdk/clients/rest/models/event_order_by_direction.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …atchet_sdk/clients/rest/models/v1_task_summary_list.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …chet_sdk/clients/rest/models/workflow_workers_count.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …on/hatchet_sdk/clients/rest/models/step_run_archive.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …/hatchet_sdk/clients/rest/models/workflow_run_shape.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …hatchet_sdk/clients/rest/models/concurrency_setting.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …ts/rest/models/v1_create_webhook_request_basic_auth.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …python/hatchet_sdk/clients/rest/models/worker_label.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …hatchet_sdk/clients/rest/models/scheduled_workflows.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …hon/hatchet_sdk/clients/rest/models/feature_flag_id.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| HIGH | …dk/clients/rest/models/create_tenant_invite_request.py | 0 | hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-g | STRING |
| 859 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | frontend/app/src/query-client.tsx | 24 | function setupExchangeTokenRefreshTriggers() { | CODE |
| LOW | frontend/app/src/router.tsx | 421 | async function getOrganizationIdForTenantInRouter(tenantId: string) { | CODE |
| LOW | frontend/app/src/components/v1/ui/chart.tsx | 324 | function getPayloadConfigFromPayload( | CODE |
| LOW | …mponents/v1/molecules/time-picker/time-picker-utils.ts | 99 | function getValidArrowMinuteOrSecond(value: string, step: number) { | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 250 | function nestChildWorkflowRunsUnderProducers(nodes: OtelSpanTree[]): void { | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 287 | function suppressStandaloneQueuedSpans(nodes: OtelSpanTree[]): void { | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 295 | function synthesizeInProgressSpans( | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 407 | function suppressOrphanedChildWorkflows( | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 479 | function synthesizePendingTaskSpans( | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 570 | function attachWorkflowQueuedPhase( | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 742 | function computeDurationFromChildren(node: OtelSpanTree): void { | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 792 | function buildTreeFromTaskSummaries( | CODE |
| LOW | …/components/v1/cloud/billing/subscription-plan-code.ts | 7 | export function resolveSubscriptionPlanCode( | CODE |
| LOW | …/components/v1/cloud/billing/subscription-plan-code.ts | 29 | export function canSelfServePayAsYouGoUpgrade(planCode?: string | null) { | CODE |
| LOW | …/app/src/components/v1/cloud/billing/usage-features.ts | 81 | export function inventoryAllowancesFromPlan( | CODE |
| LOW | …nents/forms/organization-onboarding-questions-form.tsx | 51 | export function shuffledAttributionOptions(): AttributionOption[] { | CODE |
| LOW | …nents/forms/organization-onboarding-questions-form.tsx | 81 | export function OrganizationOnboardingQuestionsForm({ | CODE |
| LOW | …app/src/components/sso/SsoDeleteConfirmationDialog.tsx | 13 | export function SsoDeleteConfirmationDialog() { | CODE |
| LOW | frontend/app/src/hooks/use-organization-entitlements.ts | 12 | export function useOrganizationEntitlements(organizationId?: string | null) { | CODE |
| LOW | frontend/app/src/hooks/use-subscription-upgrade.ts | 15 | export function getPlanChangeErrorMessage(error: unknown) { | CODE |
| LOW | frontend/app/src/hooks/notifications/dismissed.ts | 26 | export function isLimitNotificationDismissed( | CODE |
| LOW | frontend/app/src/hooks/notifications/dismissed.ts | 33 | export function useDismissedLimitNotifications() { | CODE |
| LOW | frontend/app/src/lib/breadcrumbs.ts | 157 | function generateOrganizationBreadcrumbs( | CODE |
| LOW | frontend/app/src/lib/redirect-frontend-host.ts | 3 | export function domainRedirectSkipStorageKey(targetOrigin: string): string { | CODE |
| LOW | frontend/app/src/lib/redirect-frontend-host.ts | 7 | export function parseRedirectFrontendOrigin(raw: string): URL | null { | CODE |
| LOW | frontend/app/src/lib/redirect-frontend-host.ts | 22 | export function buildRedirectFrontendHref( | CODE |
| LOW | frontend/app/src/lib/utils/retention.ts | 102 | export function isTimeWindowOutsideRetention( | CODE |
| LOW | frontend/app/src/lib/utils/retention.ts | 134 | export function defaultTimeWindowForRetention( | CODE |
| LOW | frontend/app/src/lib/api/exchange-token.ts | 62 | export function exchangeTokenQueryOptions( | CODE |
| LOW | frontend/app/src/lib/api/api.ts | 127 | export function resolveExchangeTokenTenantId( | CODE |
| LOW | frontend/app/src/lib/api/api.ts | 198 | async function resolveControlPlaneEnabled(): Promise<boolean> { | CODE |
| LOW | …app/src/pages/organizations/$organization/sections.tsx | 40 | export function OrganizationCompliancePage() { | CODE |
| LOW | …/app/src/pages/organizations/$organization/billing.tsx | 131 | function OrganizationBillingContent() { | CODE |
| LOW | …c/pages/main/v1/tenant-settings/organization/index.tsx | 266 | export function CloudOrganizationSettings({ | CODE |
| LOW | …ng/components/update-tenant-alerting-settings-form.tsx | 34 | export function UpdateTenantAlertingSettings({ | CODE |
| LOW | …ntegrations/components/prometheus-metrics-settings.tsx | 35 | export function PrometheusMetricsSettings() { | CODE |
| LOW | …ntegrations/components/prometheus-metrics-settings.tsx | 180 | function MetricsSelfHostInstructions({ tenantId }: { tenantId: string }) { | CODE |
| LOW | …rce-limits/components/tenant-resource-limits-table.tsx | 21 | export function TenantResourceLimitsTable({ | CODE |
| LOW | …led-runs/components/expanded-scheduled-run-content.tsx | 10 | export function ExpandedScheduledRunContent({ | CODE |
| LOW | …led-runs/components/bulk-reschedule-scheduled-runs.tsx | 13 | export function BulkRescheduleScheduledRuns({ | CODE |
| LOW | …rkflow-runs-v1/components/runs-timeout-empty-state.tsx | 8 | export function RequestTimeoutCloudCTAEmptyState({ | CODE |
| LOW | …in/v1/workflow-runs-v1/hooks/use-run-detail-search.tsx | 175 | export function RunDetailSearchLocalProvider({ | CODE |
| LOW | …$run/v2components/step-run-events-for-workflow-run.tsx | 257 | function describeConditionCompletion(c: { | CODE |
| LOW | …/main/v1/workflow-runs-v1/$run/v2components/header.tsx | 165 | function TriggeringParentWorkflowRunSection({ | CODE |
| LOW | …/$run/v2components/step-run-detail/step-run-detail.tsx | 416 | function TriggeringParentWorkflowRunSection({ | CODE |
| LOW | …d-worker/components/managed-worker-instances-table.tsx | 17 | export function ManagedWorkerInstancesTable({ | CODE |
| LOW | frontend/docs/scripts/generate-llms.ts | 524 | function resolveMdxComponentImports( | CODE |
| LOW | frontend/docs/lib/docs-languages.ts | 41 | export function getFixedPackageManagerMessage( | CODE |
| LOW | …nd/vscode-extension/src/providers/codelens-provider.ts | 21 | export function detectWorkflowDeclarations( | CODE |
| LOW | …nd/vscode-extension/src/providers/codelens-provider.ts | 65 | function parseWorkflowsForDocument( | CODE |
| LOW | …ntend/vscode-extension/src/parser/jsdoc-annotations.ts | 36 | export function scanFileForWorkflowAnnotations( | CODE |
| LOW | …ntend/vscode-extension/src/parser/jsdoc-annotations.ts | 103 | function tryExtractFromVariableStatement( | CODE |
| LOW | frontend/vscode-extension/src/parser/go-parser.ts | 125 | export function detectGoWorkflowDeclarations(source: string): WorkflowDeclaration[] { | CODE |
| LOW | frontend/vscode-extension/src/parser/python-parser.ts | 109 | export function detectPyWorkflowDeclarations(source: string): WorkflowDeclaration[] { | CODE |
| LOW | frontend/vscode-extension/src/parser/ruby-parser.ts | 117 | export function detectRubyWorkflowDeclarations(source: string): WorkflowDeclaration[] { | CODE |
| LOW | frontend/vscode-extension/src/parser/workflow-parser.ts | 124 | function extractWorkflowNameFromArgs(call: ts.CallExpression): string | undefined { | CODE |
| LOW | frontend/vscode-extension/src/parser/workflow-parser.ts | 430 | export function detectTsWorkflowDeclarations( | CODE |
| LOW | sdks/python/conftest.py | 26 | async def supports_durable_eviction(engine_version: str | None) -> bool: | CODE |
| LOW | sdks/python/conftest.py | 33 | def _skip_unless_durable_eviction(supports_durable_eviction: bool) -> None: | CODE |
| LOW | sdks/python/conftest.py | 48 | def _skip_unless_observability(supports_observability: bool) -> None: | CODE |
| 1168 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | sdks/python/tests/test_durable_eviction_cache.py | 1 | CODE | |
| LOW | sdks/python/tests/test_datetime_partitioning.py | 1 | CODE | |
| LOW | sdks/python/tests/test_cel_debugging.py | 6 | CODE | |
| LOW | …/concurrency_strategies/test_concurrency_strategies.py | 9 | CODE | |
| LOW | sdks/python/tests/unit/test_durable_event_listener.py | 1 | CODE | |
| LOW | sdks/python/tests/unit/test_durable_event_listener.py | 12 | CODE | |
| LOW | sdks/python/tests/unit/test_invocation_scoped_cache.py | 1 | CODE | |
| LOW | sdks/python/tests/unit/conftest.py | 4 | CODE | |
| LOW | sdks/python/tests/unit/test_aio_put_stream.py | 1 | CODE | |
| LOW | sdks/python/tests/unit/test_capture_logs.py | 1 | CODE | |
| LOW | sdks/python/tests/unit/test_shutdown_ordering.py | 3 | CODE | |
| LOW | …ks/python/tests/unit/test_batch_run_instrumentation.py | 8 | CODE | |
| LOW | sdks/python/tests/unit/test_durable_eviction_manager.py | 1 | CODE | |
| LOW | …failure_on_timeout_with_multi_concurrency/test_case.py | 8 | CODE | |
| LOW | sdks/python/tests/child_spawn_cache_on_retry/worker.py | 4 | CODE | |
| LOW | …pawn_cache_on_retry/test_child_spawn_cache_on_retry.py | 7 | CODE | |
| LOW | sdks/python/hatchet_sdk/labels.py | 1 | CODE | |
| LOW | sdks/python/hatchet_sdk/labels.py | 1 | CODE | |
| LOW | sdks/python/hatchet_sdk/workflow_run.py | 14 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 14 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 17 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 17 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 17 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 24 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 25 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 26 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 27 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 28 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 29 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 30 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 31 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 32 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 35 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 38 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 41 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 44 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 45 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 46 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 47 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 48 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 49 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 52 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 53 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 56 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 59 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 60 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 61 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 62 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 65 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 68 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 69 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 70 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 71 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 74 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 75 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 76 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 77 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 78 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 79 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 80 | CODE | |
| 1270 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | frontend/app/src/lib/api/user-wrapper.ts | 14 | // ── Queries ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/user-wrapper.ts | 66 | // ── Mutations ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/tenant-wrapper.ts | 16 | // ── Queries ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/tenant-wrapper.ts | 58 | // ── Mutations ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/organization-wrapper.ts | 65 | // ── Queries ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/organization-wrapper.ts | 148 | // ── Mutations ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/organization-wrapper.ts | 401 | // ── User Groups ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/EmbeddedMode.tsx | 65 | // ─── Timing (ms) ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/EmbeddedMode.tsx | 86 | // ─── Component boxes (persistent tokens: separate → merged → reset) ──────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/EmbeddedMode.tsx | 108 | // ─── Phase scenery (links, labels, boundary — fading tokens) ─────────────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/EmbeddedMode.tsx | 156 | // ─── Chatter (dispatch → result → persist, in both phases) ───────────────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/EmbeddedMode.tsx | 222 | // ─── Export ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/docs/components/flow-animations/QueueBackpressure.tsx | 70 | // ─── Timing (ms) ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/docs/components/flow-animations/QueueBackpressure.tsx | 96 | // ─── Schedule (FIFO simulation, run once at module scope) ────────────────── | COMMENT |
| MEDIUM | …/docs/components/flow-animations/QueueBackpressure.tsx | 165 | // ─── Task tracks ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/docs/components/flow-animations/QueueBackpressure.tsx | 228 | // ─── Live readouts (per-frame, no React renders) ─────────────────────────── | COMMENT |
| MEDIUM | …/docs/components/flow-animations/QueueBackpressure.tsx | 336 | // ─── Static chrome ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/docs/components/flow-animations/QueueBackpressure.tsx | 464 | // ─── Export ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/EventFanout.tsx | 50 | // ─── The event and the tasks subscribed to it ────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/EventFanout.tsx | 67 | // ─── Timing constants (ms) ───────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/EventFanout.tsx | 79 | // ─── Seeded schedule: four pushes of the same event ──────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/EventFanout.tsx | 117 | // ─── Loop bookkeeping ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/EventFanout.tsx | 126 | // ─── Tracks ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/EventFanout.tsx | 197 | // ─── Static chrome ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/EventFanout.tsx | 326 | // ─── Export ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 76 | // ─── Buckets ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 85 | // ─── Timing (ms) ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 110 | // ─── Schedule (round-robin simulation, run once at module scope) ─────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 248 | // ─── Object tracks (bucket → queue → worker slot → tally) ────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 334 | // ─── list_objects trigger tracks (cron port → bucket, one per lane) ──────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 378 | // ─── Cron pulse rings ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 395 | // ─── Round-robin cursor (glides to the queue head being pulled) ──────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 442 | // ─── Live readouts (per-frame, no React renders) ─────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 576 | // ─── Static chrome ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/S3Pipeline.tsx | 750 | // ─── Export ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/SlotCost.tsx | 60 | // ─── Timing (ms) ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/SlotCost.tsx | 87 | // ─── Loop wrapping ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/SlotCost.tsx | 146 | // ─── Light tasks (cost 1): per-cell occupancy schedules ──────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/SlotCost.tsx | 324 | // ─── Heavy tasks (cost 5): one bar per column reservation ────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/SlotCost.tsx | 405 | // ─── Static chrome ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/flow-animations/SlotCost.tsx | 509 | // ─── Export ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …d/docs/components/flow-animations/DurableExecution.tsx | 62 | // ─── Timing (ms) — one scripted crash-and-replay loop ────────────────────── | COMMENT |
| MEDIUM | …d/docs/components/flow-animations/DurableExecution.tsx | 90 | // ─── Task tracks ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …d/docs/components/flow-animations/DurableExecution.tsx | 139 | // ─── Checkpoint chips + log records ──────────────────────────────────────── | COMMENT |
| MEDIUM | …d/docs/components/flow-animations/DurableExecution.tsx | 217 | // ─── State machines: step cells + worker frames ──────────────────────────── | COMMENT |
| MEDIUM | …d/docs/components/flow-animations/DurableExecution.tsx | 305 | // ─── Beat annotations (subtitle strip) ───────────────────────────────────── | COMMENT |
| MEDIUM | …d/docs/components/flow-animations/DurableExecution.tsx | 319 | // ─── Static chrome ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …d/docs/components/flow-animations/DurableExecution.tsx | 448 | // ─── Export ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/DurableWaits.tsx | 64 | // ─── Timing (ms) — one scripted sleep loop ───────────────────────────────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/DurableWaits.tsx | 92 | // ─── Track builders ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/DurableWaits.tsx | 172 | // ─── Worker state: slot occupancy, load meter, idle dimming ──────────────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/DurableWaits.tsx | 225 | // ─── Static chrome ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ntend/docs/components/flow-animations/DurableWaits.tsx | 352 | // ─── Export ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/HumanInLoop.tsx | 62 | // ─── Timing (ms) — one scripted approval loop ────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/HumanInLoop.tsx | 85 | // ─── Track builders ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/HumanInLoop.tsx | 173 | // ─── Worker state: slot occupancy, load meter, idle dimming ──────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/HumanInLoop.tsx | 226 | // ─── Static chrome ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ontend/docs/components/flow-animations/HumanInLoop.tsx | 369 | // ─── Export ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …docs/components/flow-animations/HeadOfLineBlocking.tsx | 66 | // ─── Timing (ms) ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …docs/components/flow-animations/HeadOfLineBlocking.tsx | 99 | // ─── Flood schedule (seeded jitter — deterministic, never Math.random) ───── | COMMENT |
| 83 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | cmd/hatchet-loadtest/timing.go | 21 | const timingPendingTTL = 5 * time.Minute | COMMENT |
| LOW | cmd/hatchet-loadtest/timing.go | 241 | // being retried after a prior failure) - don't reconsider it. | COMMENT |
| LOW | cmd/hatchet-cli/cli/embedded_ui_session.go | 61 | // loginBackoff is the minimum interval between login attempts, whatever | COMMENT |
| LOW | cmd/hatchet-cli/cli/embedded_ui_session.go | 81 | // 'hatchet embedded-ui', so the user should never see a login screen: when a | COMMENT |
| LOW | cmd/hatchet-cli/cli/client.go | 61 | analytics.SourceMetadataKey: string(analytics.SourceCLI), | COMMENT |
| LOW | …chet-cli/cli/internal/patternmatcher/patternmatcher.go | 81 | // and isn't excluded by any of the subsequent patterns. | COMMENT |
| LOW | …chet-cli/cli/internal/patternmatcher/patternmatcher.go | 161 | } | COMMENT |
| LOW | cmd/hatchet-cli/cli/internal/mcp/resolve.go | 61 | // Embedded engines register themselves in the profile store under the | COMMENT |
| LOW | cmd/hatchet-cli/cli/internal/mcp/resolve.go | 201 | COMMENT | |
| LOW | frontend/app/.eslintrc.json | 61 | // "@typescript-eslint/no-explicit-any": "error", | COMMENT |
| LOW | frontend/app/.eslintrc.json | 81 | // "no-alert": "error", | COMMENT |
| LOW | frontend/app/.eslintrc.json | 101 | // // We should turn this on later to enforce using `useCallback` instead of inline functions | COMMENT |
| LOW | …ows/$workflow/components/workflow-general-settings.tsx | 121 | )} | COMMENT |
| LOW | …main/v1/overview/components/use-onboarding-progress.ts | 21 | try { | COMMENT |
| LOW | …naged-workers/create/components/create-worker-form.tsx | 421 | ) { | COMMENT |
| LOW | …naged-workers/create/components/create-worker-form.tsx | 441 | // href="/api/v1/cloud/users/github-app/start" | COMMENT |
| LOW | sdks/go/hatchet.go | 1 | // Define workflows that can declare tasks and be run, scheduled, and so on. | COMMENT |
| LOW | sdks/go/hatchet.go | 21 | // | COMMENT |
| LOW | sdks/go/hatchet.go | 41 | // - Nested workflow execution: https://github.com/hatchet-dev/hatchet/tree/main/sdks/go/examples/child-workflows | COMMENT |
| LOW | sdks/go/hatchet.go | 61 | // | COMMENT |
| LOW | sdks/go/hatchet.go | 81 | // - Crons: https://docs.hatchet.run/reference/go/feature-clients/crons.md (guide: https://docs.hatchet.run/v1/cron-ru | COMMENT |
| LOW | sdks/go/client.go | 781 | } | COMMENT |
| LOW | sdks/go/client.go | 1001 | // If we can't find the specific task, return the entire result | COMMENT |
| LOW | sdks/go/deprecation.go | 41 | COMMENT | |
| LOW | sdks/go/workflow.go | 681 | COMMENT | |
| LOW | sdks/go/docs/generator/main.go | 1 | // Command generator emits the Go SDK reference docs (fumadocs .mdx pages) from the | COMMENT |
| LOW | sdks/python/hatchet_sdk/deprecated/__init__.py | 1 | # Legacy worker registration code for backward compatibility with older Hatchet engines | COMMENT |
| LOW | sdks/python/examples/durable/test_durable.py | 101 | async def test_durable_workflow(hatchet: Hatchet) -> None: | COMMENT |
| LOW | sdks/python/examples/delayed/test_delayed.py | 1 | # from hatchet_sdk import Hatchet | COMMENT |
| LOW | sdks/typescript/generate-protoc-es.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | sdks/typescript/tsconfig.json | 21 | "lib": ["ES2022"], | COMMENT |
| LOW | sdks/typescript/tsconfig.json | 41 | "@hatchet/*": ["./src/*"], | COMMENT |
| LOW | sdks/typescript/tsconfig.json | 61 | COMMENT | |
| LOW | sdks/typescript/tsconfig.json | 81 | // "mapRoot": "", /* Specify the location where debugger should locate map files | COMMENT |
| LOW | sdks/typescript/tsconfig.json | 101 | "strict": true /* Enable all strict type-checking options. */, | COMMENT |
| LOW | sdks/typescript/jest.config.ts | 21 | // Indicates whether the coverage information should be collected while executing the test | COMMENT |
| LOW | sdks/typescript/jest.config.ts | 41 | // "text", | COMMENT |
| LOW | sdks/typescript/jest.config.ts | 61 | // forceCoverageMatch: [], | COMMENT |
| LOW | sdks/typescript/jest.config.ts | 81 | // moduleFileExtensions: [ | COMMENT |
| LOW | sdks/typescript/jest.config.ts | 101 | // An enum that specifies notification mode. Requires { notify: true } | COMMENT |
| LOW | sdks/typescript/jest.config.ts | 121 | COMMENT | |
| LOW | sdks/typescript/jest.config.ts | 141 | COMMENT | |
| LOW | sdks/typescript/jest.config.ts | 181 | '^@hatchet/(.*)$': '<rootDir>/src/$1', | COMMENT |
| LOW | …rency_workflow_level/concurrency_workflow_level.e2e.ts | 21 | // A workflow run holds its workflow-level concurrency slots from the moment its | COMMENT |
| LOW | sdks/typescript/src/v1/client/worker/health-server.ts | 81 | } | COMMENT |
| LOW | …escript/src/clients/dispatcher/action-listener.test.ts | 81 | // const listener = new ActionListener( | COMMENT |
| LOW | …escript/src/clients/dispatcher/action-listener.test.ts | 101 | // taskId: 'step1', | COMMENT |
| LOW | …escript/src/clients/dispatcher/action-listener.test.ts | 121 | // res.push(action); | COMMENT |
| LOW | …escript/src/clients/dispatcher/action-listener.test.ts | 141 | // it('it should attempt to re-establish connection on grpc UNAVAILABLE', async () => { | COMMENT |
| LOW | …escript/src/clients/dispatcher/action-listener.test.ts | 161 | // mockListener(mockAssignedActions), | COMMENT |
| LOW | …escript/src/clients/dispatcher/action-listener.test.ts | 181 | // // throw new Error('Simulated error'); | COMMENT |
| LOW | …escript/src/clients/dispatcher/action-listener.test.ts | 201 | // await listener.getListenClient(); | COMMENT |
| LOW | …escript/src/clients/dispatcher/action-listener.test.ts | 221 | // }) | COMMENT |
| LOW | …escript/src/clients/dispatcher/action-listener.test.ts | 241 | describe('unregister', () => { | COMMENT |
| LOW | …cript/src/clients/dispatcher/dispatcher-client.test.ts | 61 | // tenantId: 'TENANT_ID', | COMMENT |
| LOW | sdks/typescript/src/protoc-es/google/rpc/status_pb.ts | 1 | // Copyright 2025 Google LLC | COMMENT |
| LOW | sdks/ruby/generate.sh | 1 | #!/bin/bash | COMMENT |
| LOW | sdks/ruby/docs/generate.rb | 1 | # frozen_string_literal: true | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 81 | # namespace: "production" | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 201 | # scheduled, and so on. | COMMENT |
| 300 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …/pages/main/v1/managed-workers/demo-template/index.tsx | 202 | // Check if deployment is complete - make success detection more robust | COMMENT |
| LOW | …et/clients/rest/lib/hatchet-sdk-rest/api_model_base.rb | 71 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …est/lib/hatchet-sdk-rest/models/step_run_event_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …t/lib/hatchet-sdk-rest/models/v1_cel_debug_response.rb | 260 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …/lib/hatchet-sdk-rest/models/webhook_worker_created.rb | 299 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …est/lib/hatchet-sdk-rest/models/v1_webhook_response.rb | 220 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …tchet-sdk-rest/models/v1_event_workflow_run_summary.rb | 327 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …st/lib/hatchet-sdk-rest/models/v1_webhook_hmac_auth.rb | 322 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …het-sdk-rest/models/event_update_cancel200_response.rb | 203 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …nts/rest/lib/hatchet-sdk-rest/models/v1_task_timing.rb | 572 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …rest/lib/hatchet-sdk-rest/models/trigger_run_result.rb | 237 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …chet-sdk-rest/models/v1_create_webhook_request_base.rb | 325 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …est/lib/hatchet-sdk-rest/models/cron_workflows_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …/rest/lib/hatchet-sdk-rest/models/workflow_run_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …t/clients/rest/lib/hatchet-sdk-rest/models/step_run.rb | 537 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …s/rest/lib/hatchet-sdk-rest/models/concurrency_stat.rb | 221 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …lients/rest/lib/hatchet-sdk-rest/models/tenant_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …et-sdk-rest/models/workflow_version_task_rate_limit.rb | 252 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …nts/rest/lib/hatchet-sdk-rest/models/otel_span_list.rb | 223 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …rest/models/create_tenant_alert_email_group_request.rb | 221 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …b/hatchet-sdk-rest/models/v1_update_webhook_request.rb | 232 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …atchet-sdk-rest/models/user_tenant_memberships_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …t/lib/hatchet-sdk-rest/models/update_tenant_request.rb | 294 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …/lib/hatchet-sdk-rest/models/tenant_resource_policy.rb | 221 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …lients/rest/lib/hatchet-sdk-rest/models/v1_log_line.rb | 373 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …est/lib/hatchet-sdk-rest/models/list_slack_webhooks.rb | 246 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …rest/lib/hatchet-sdk-rest/models/user_login_request.rb | 246 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …clients/rest/lib/hatchet-sdk-rest/models/event_data.rb | 219 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ents/rest/lib/hatchet-sdk-rest/models/slack_webhook.rb | 353 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …atchet-sdk-rest/models/user_change_password_request.rb | 246 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ib/hatchet-sdk-rest/models/scheduled_workflows_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …chet-sdk-rest/models/v1_create_webhook_request_hmac.rb | 387 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …nts/rest/lib/hatchet-sdk-rest/models/webhook_worker.rb | 272 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …t/lib/hatchet-sdk-rest/models/v1_webhook_basic_auth.rb | 246 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …t/clients/rest/lib/hatchet-sdk-rest/models/workflow.rb | 369 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …/lib/hatchet-sdk-rest/models/webhook_worker_request.rb | 295 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …st/lib/hatchet-sdk-rest/models/v1_task_point_metric.rb | 270 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …b/hatchet-sdk-rest/models/bulk_create_event_request.rb | 220 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …t-sdk-rest/models/v1_create_webhook_request_api_key.rb | 387 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ts/rest/lib/hatchet-sdk-rest/models/v1_task_summary.rb | 833 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ls/workflow_run_shape_item_for_workflow_run_details.rb | 334 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …lients/rest/lib/hatchet-sdk-rest/models/worker_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …nts/rest/lib/hatchet-sdk-rest/models/v1_task_filter.rb | 260 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …t/lib/hatchet-sdk-rest/models/v1_stream_payload_ref.rb | 219 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …hatchet-sdk-rest/models/list_pull_requests_response.rb | 220 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …nts/rest/lib/hatchet-sdk-rest/models/cron_workflows.rb | 490 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ts/rest/lib/hatchet-sdk-rest/models/rate_limit_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …t/lib/hatchet-sdk-rest/models/v1_workflow_run_count.rb | 219 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …/rest/lib/hatchet-sdk-rest/models/api_resource_meta.rb | 291 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …est/lib/hatchet-sdk-rest/models/worker_runtime_info.rb | 259 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …atchet-sdk-rest/models/workflow_runs_cancel_request.rb | 220 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …/lib/hatchet-sdk-rest/models/rerun_step_run_request.rb | 218 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ents/rest/lib/hatchet-sdk-rest/models/workflow_list.rb | 221 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ts/rest/lib/hatchet-sdk-rest/models/v1_webhook_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …rest/lib/hatchet-sdk-rest/models/tenant_invite_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ib/hatchet-sdk-rest/models/tenant_alerting_settings.rb | 295 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …dk-rest/models/create_cron_workflow_trigger_request.rb | 333 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ients/rest/lib/hatchet-sdk-rest/models/workflow_tag.rb | 246 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …chet-sdk-rest/models/v1_branch_durable_task_request.rb | 291 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …s/rest/lib/hatchet-sdk-rest/models/workflow_version.rb | 394 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| 143 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | sdks/python/tests/unit/test_durable_event_listener.py | 399 | s2.push( | CODE |
| HIGH | sdks/python/examples/concurrency_limit_rr_load/event.py | 13 | hatchet.event.push("concurrency-test", {"group": group}) | CODE |
| HIGH | …amples/opentelemetry_instrumentation/hyperdx/worker.py | 77 | hatchet.event.push( | CODE |
| HIGH⚡ | sdks/python/examples/durable/test_durable.py | 459 | hatchet.event.push(EVENT_KEY, {"order": "first"}, scope=scope) | CODE |
| HIGH⚡ | sdks/python/examples/durable/test_durable.py | 471 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 210 | hatchet.event.push(EVENT_KEY, {"test": "test"}) | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 439 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 484 | hatchet.event.push("key1", {"order": "first"}, scope=scope) | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 503 | event = hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/durable/trigger.py | 19 | hatchet.event.push(EVENT_KEY, AwaitedEvent(id="123").model_dump(mode="json")) | CODE |
| HIGH | sdks/python/examples/conditions/trigger.py | 9 | hatchet.event.push("skip_on_event:skip", {}) | CODE |
| HIGH | sdks/python/examples/conditions/trigger.py | 10 | hatchet.event.push("wait_for_event:start", {}) | CODE |
| HIGH | sdks/python/examples/welcome_email/trigger.py | 20 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/durable_event/trigger.py | 17 | hatchet.event.push( | CODE |
| HIGH | …hon/examples/durable_eviction/test_durable_eviction.py | 203 | hatchet.event.push(EVENT_KEY, {}) | CODE |
| HIGH | …hon/examples/durable_eviction/test_durable_eviction.py | 222 | hatchet.event.push(MEMO_EVENT_KEY, {}) | CODE |
| HIGH | sdks/python/examples/events/event.py | 7 | hatchet.event.push("user:create", {"should_skip": False}) | CODE |
| HIGH | sdks/python/examples/events/event.py | 11 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/events/test_event.py | 49 | or f"input.should_skip == false && payload.test_run_id == '{test_run_id}'" | CODE |
| HIGH | sdks/python/examples/events/test_event.py | 236 | e = hatchet.event.push(EVENT_KEY, cp(False)) | CODE |
| HIGH | sdks/python/examples/events/test_event.py | 436 | "input.should_skip == false && payload.foobar == 'baz'", | CODE |
| HIGH | sdks/python/examples/events/test_event.py | 460 | "input.should_skip == false && payload.foobar == 'baz'", | CODE |
| HIGH | sdks/python/examples/events/filter.py | 23 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/events/filter.py | 33 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/support_agent/trigger.py | 22 | hatchet.event.push( | CODE |
| HIGH | hack/db/generate-oss-db-model.py | 476 | const state = {{ scale: 0.55, x: 20, y: 20, selected: null, visible: new Set() }}; | CODE |
| HIGH | hack/db/generate-oss-db-model.py | 524 | if (column.primaryKey && column.foreignKey) return 'PK/FK'; | CODE |
| HIGH | hack/db/generate-oss-db-model.py | 596 | edgeElements.push(path); | CODE |
| HIGH⚡ | hack/db/generate-oss-db-model.py | 640 | if (column.primaryKey) labels.push('primary key'); | CODE |
| HIGH⚡ | hack/db/generate-oss-db-model.py | 641 | if (column.foreignKey) labels.push('foreign key'); | CODE |
| HIGH⚡ | hack/db/generate-oss-db-model.py | 642 | if (column.default !== null) labels.push(`default: ${{column.default}}`); | CODE |
| HIGH⚡ | hack/db/generate-oss-db-model.py | 642 | if (column.default !== null) labels.push(`default: ${{column.default}}`); | CODE |
| HIGH⚡ | hack/db/generate-oss-db-model.py | 683 | for (const edge of edgeElements) edge.classList.toggle('active', edge.dataset.source === name || edge.dataset.target = | CODE |
| HIGH⚡ | hack/db/generate-oss-db-model.py | 687 | if (center && positions.has(name)) centerTable(name); | CODE |
| HIGH⚡ | hack/db/generate-oss-db-model.py | 696 | const visible = (!source || table.source === source) && (!query || haystack.includes(query)); | CODE |
| HIGH⚡ | hack/db/generate-oss-db-model.py | 704 | const anyVisible = hatchetOssModel.tables.some(table => table.source === label.dataset.source && state.visible.has(t | CODE |
| HIGH | hack/db/generate-oss-db-model.py | 742 | let drag = null; | CODE |
| HIGH | hack/db/generate-oss-db-model.py | 755 | viewport.addEventListener('pointerup', () => {{ drag = null; viewport.classList.remove('dragging'); }}); | CODE |
| HIGH | hack/db/generate-oss-db-model.py | 761 | viewport.addEventListener('click', () => selectTable(null, false)); | CODE |
| HIGH⚡ | hack/dev/compression-test/tests/python_test.py | 39 | hatchet.event.push("compression-test:event", event) | CODE |
| HIGH | examples/python/concurrency_limit_rr_load/event.py | 13 | hatchet.event.push("concurrency-test", {"group": group}) | CODE |
| HIGH | …python/opentelemetry_instrumentation/hyperdx/worker.py | 77 | hatchet.event.push( | CODE |
| HIGH | examples/python/durable/trigger.py | 19 | hatchet.event.push(EVENT_KEY, AwaitedEvent(id="123").model_dump(mode="json")) | CODE |
| HIGH | examples/python/conditions/trigger.py | 9 | hatchet.event.push("skip_on_event:skip", {}) | CODE |
| HIGH | examples/python/conditions/trigger.py | 10 | hatchet.event.push("wait_for_event:start", {}) | CODE |
| HIGH | examples/python/welcome_email/trigger.py | 20 | hatchet.event.push( | CODE |
| HIGH | examples/python/durable_event/trigger.py | 17 | hatchet.event.push( | CODE |
| HIGH | examples/python/events/event.py | 7 | hatchet.event.push("user:create", {"should_skip": False}) | CODE |
| HIGH | examples/python/events/event.py | 10 | hatchet.event.push( | CODE |
| HIGH | examples/python/events/filter.py | 22 | hatchet.event.push( | CODE |
| HIGH | examples/python/events/filter.py | 31 | hatchet.event.push( | CODE |
| HIGH | examples/python/support_agent/trigger.py | 22 | hatchet.event.push( | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | Taskfile.yaml | 344 | # Create a trap to kill the watcher when the task exits | COMMENT |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 40 | # Create a new profile (interactive) | COMMENT |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 43 | # Create a new profile (non-interactive) | COMMENT |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 83 | Example: ` # Create a new profile interactively (prompts for token) | CODE |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 86 | # Create a new profile with a specific name | COMMENT |
| MEDIUM | sdks/python/hatchet_sdk/logger.py | 4 | # Create a named logger | COMMENT |
| MEDIUM | …ks/python/hatchet_sdk/contracts/dispatcher_pb2_grpc.py | 316 | # This class is part of an EXPERIMENTAL API. | COMMENT |
| MEDIUM | sdks/python/hatchet_sdk/contracts/events_pb2_grpc.py | 132 | # This class is part of an EXPERIMENTAL API. | COMMENT |
| MEDIUM | sdks/python/hatchet_sdk/contracts/workflows_pb2_grpc.py | 135 | # This class is part of an EXPERIMENTAL API. | COMMENT |
| MEDIUM | …python/hatchet_sdk/contracts/v1/dispatcher_pb2_grpc.py | 101 | # This class is part of an EXPERIMENTAL API. | COMMENT |
| MEDIUM | …/python/hatchet_sdk/contracts/v1/workflows_pb2_grpc.py | 150 | # This class is part of an EXPERIMENTAL API. | COMMENT |
| MEDIUM | sdks/python/examples/concurrency_limit_rr_load/event.py | 7 | # Create a list of events with desired distribution | COMMENT |
| MEDIUM | sdks/ruby/src/spec/hatchet/features/runs_spec.rb | 40 | # Create the client to trigger the API initialization | COMMENT |
| MEDIUM | …s/ruby/src/spec/integration/events_integration_spec.rb | 331 | # Create a unique event first | COMMENT |
| MEDIUM | sdks/ruby/src/spec/support/integration_helper.rb | 16 | # Create a test client for integration tests | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet-sdk.rb | 200 | # Define a Hatchet workflow, which can then declare tasks and be run, | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet-sdk.rb | 221 | # Create a standalone Hatchet task. The task is automatically wrapped in a | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet-sdk.rb | 244 | # Create a standalone batch task (auto-wraps in a single-task workflow). | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet-sdk.rb | 268 | # Create a standalone _durable_ Hatchet task, which works using Hatchet's | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet-sdk.rb | 287 | # Create a Hatchet worker on which to run workflows. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/worker_obj.rb | 257 | # Create the action listener with retry/reconnect logic | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 101 | # Define a task within this workflow. The block receives the workflow input | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 132 | # Define a durable task within this workflow. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 146 | # Define a batch task within this workflow. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 165 | # Define an on_failure task for this workflow | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 180 | # Define an on_success task for this workflow | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 306 | # Create a bulk run item for this workflow, intended to be used with the | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 333 | # Create a cron trigger for this workflow. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/durable_context.rb | 178 | # Create a request enumerator for the bidi stream | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/clients.rb | 4 | # This module provides access to different client types (REST, gRPC, etc.) | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/clients.rb | 19 | # Create a REST API client using the provided Hatchet configuration | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/connection.rb | 20 | # Create a new gRPC channel for the given configuration. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/conditions.rb | 103 | # Create an OR condition group | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/task.rb | 267 | # Create a bulk run item for use with run_many | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/clients/rest.rb | 26 | # Create a Configuration instance from a Hatchet::Config | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/clients/rest/.rubocop.yml | 1 | # This file is based on https://github.com/rails/rails/blob/master/.rubocop.yml (MIT license) | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/clients/rest/.rubocop.yml | 87 | # Defining a method with parameters needs parentheses. | COMMENT |
| MEDIUM⚡ | …et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb | 22 | # Create a filter | COMMENT |
| MEDIUM⚡ | …et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb | 23 | # Create a new filter | COMMENT |
| MEDIUM⚡ | …et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb | 33 | # Create a filter | COMMENT |
| MEDIUM⚡ | …et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb | 34 | # Create a new filter | COMMENT |
| MEDIUM⚡ | …t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb | 22 | # Create a webhook | COMMENT |
| MEDIUM⚡ | …t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb | 23 | # Create a new webhook | COMMENT |
| MEDIUM⚡ | …t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb | 33 | # Create a webhook | COMMENT |
| MEDIUM⚡ | …t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb | 34 | # Create a new webhook | COMMENT |
| MEDIUM⚡ | …ents/rest/lib/hatchet-sdk-rest/api/workflow_run_api.rb | 23 | # Create a new cron job workflow trigger for a tenant | COMMENT |
| MEDIUM⚡ | …ents/rest/lib/hatchet-sdk-rest/api/workflow_run_api.rb | 35 | # Create a new cron job workflow trigger for a tenant | COMMENT |
| MEDIUM | …t/clients/rest/lib/hatchet-sdk-rest/api/default_api.rb | 331 | # Create a webhook | COMMENT |
| MEDIUM | …t/clients/rest/lib/hatchet-sdk-rest/api/default_api.rb | 342 | # Create a webhook | COMMENT |
| MEDIUM | …clients/rest/lib/hatchet-sdk-rest/api/api_token_api.rb | 23 | # Create an API token for a tenant | COMMENT |
| MEDIUM | …clients/rest/lib/hatchet-sdk-rest/api/api_token_api.rb | 34 | # Create an API token for a tenant | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/filters.rb | 7 | # This class provides a high-level interface for creating, retrieving, | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/filters.rb | 67 | # Create a new filter | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/rate_limits.rb | 7 | # This class provides a high-level interface for creating and updating | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/workers.rb | 7 | # This class provides a high-level interface for retrieving, listing, and | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/runs.rb | 70 | # This class provides a high-level interface for creating and managing workflow runs | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/runs.rb | 281 | # This method is intended to be an escape hatch. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/runs.rb | 368 | # This method provides an easy way to perform bulk replay operations by filters | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/runs.rb | 397 | # This method provides an easy way to perform bulk cancel operations by filters | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/scheduled.rb | 9 | # This class provides a high-level interface for creating, deleting, | COMMENT |
| 10 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | sdks/python/hatchet_sdk/hatchet.py | 319 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 343 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 366 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 445 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 481 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 516 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 664 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 696 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 728 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 760 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 794 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 930 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 966 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 1005 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/events.py | 438 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/events.py | 465 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/configuration.py | 198 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api_client.py | 137 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/log_api.py | 48 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/log_api.py | 162 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/log_api.py | 276 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/log_api.py | 491 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/log_api.py | 616 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/log_api.py | 741 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/log_api.py | 970 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/log_api.py | 1113 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/log_api.py | 1256 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/event_api.py | 1740 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/event_api.py | 1877 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/event_api.py | 2014 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/event_api.py | 3407 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/event_api.py | 3553 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/event_api.py | 3699 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/webhook_api.py | 916 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/webhook_api.py | 1013 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/webhook_api.py | 1110 | CODE | |
| LOW | …python/hatchet_sdk/clients/rest/api/rate_limits_api.py | 328 | CODE | |
| LOW | …python/hatchet_sdk/clients/rest/api/rate_limits_api.py | 430 | CODE | |
| LOW | …python/hatchet_sdk/clients/rest/api/rate_limits_api.py | 532 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/task_api.py | 1578 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/task_api.py | 1692 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/task_api.py | 1806 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/filter_api.py | 944 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/filter_api.py | 1043 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/filter_api.py | 1142 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 95 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 217 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 339 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 3226 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 3315 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 3404 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 3860 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 3980 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 4100 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 4627 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 4800 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 4973 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 6512 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 6644 | CODE | |
| LOW | …ks/python/hatchet_sdk/clients/rest/api/workflow_api.py | 6776 | CODE | |
| 83 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 11 | ## Step 1: Write Input to a Temp File | COMMENT |
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 24 | ## Step 2: Trigger the Workflow | COMMENT |
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 32 | ## Step 3: Poll for Completion | COMMENT |
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 46 | ## Step 4: Handle Failure | COMMENT |
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 66 | ## Step 5: Clean Up | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/setup-cli.md | 5 | ## Step 1: Check if Already Installed | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/setup-cli.md | 15 | ## Step 2: Install the CLI | COMMENT |
| LOW⚡ | …i/cli/skill-assets/hatchet-cli/references/setup-cli.md | 35 | ## Step 3: Choose a Connection Mode | COMMENT |
| LOW⚡ | …i/cli/skill-assets/hatchet-cli/references/setup-cli.md | 40 | ## Step 4: Check for Existing Profiles | COMMENT |
| LOW⚡ | …i/cli/skill-assets/hatchet-cli/references/setup-cli.md | 50 | ## Step 5: Create a Profile | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/setup-cli.md | 66 | ## Step 6: Verify Connectivity | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/debug-run.md | 7 | ## Step 1: Get Run State | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/debug-run.md | 21 | ## Step 2: Get Event Log | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/debug-run.md | 36 | ## Step 3: Get Logs | COMMENT |
| LOW | …/cli/skill-assets/hatchet-cli/references/replay-run.md | 7 | ## Step 1: Inspect the Original Run | COMMENT |
| LOW | …/cli/skill-assets/hatchet-cli/references/replay-run.md | 57 | ## Step 3: Watch the New Run | COMMENT |
| LOW | …ll-assets/hatchet-cli/references/local-dev-embedded.md | 7 | ## Step 1: Create an Embedded Client | COMMENT |
| LOW | …ll-assets/hatchet-cli/references/local-dev-embedded.md | 49 | ## Step 2: Run the Dev Loop | COMMENT |
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 9 | // Step 1: Login as owner and create a tenant | COMMENT |
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 64 | // Step 2: Create an invite for the member user | COMMENT |
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 84 | // Step 4: Login as member (who has pending invite) | COMMENT |
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 108 | // Step 5: Decline all invites | COMMENT |
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 141 | // Step 6: Verify the modal closes after all invites are declined | COMMENT |
| LOW⚡ | sdks/go/examples/dag/main.go | 31 | // Step 1: Initial processing | COMMENT |
| LOW⚡ | sdks/go/examples/dag/main.go | 41 | // Step 2: Depends on step 1 | COMMENT |
| LOW | sdks/go/examples/dag/main.go | 57 | // Step 3: Also depends on step 1, parallel to step 2 | COMMENT |
| LOW | sdks/go/examples/opentelemetry_instrumentation/main.go | 208 | // Step 3: Send order confirmation (runs after both payment and inventory are done). | COMMENT |
| LOW⚡ | sdks/go/examples/with-workflows/main.go | 30 | // Step 1: Initial processing | COMMENT |
| LOW⚡ | sdks/go/examples/with-workflows/main.go | 38 | // Step 2: Depends on step 1 | COMMENT |
| LOW | sdks/go/examples/with-workflows/main.go | 52 | // Step 3: Also depends on step 1, parallel to step 2 | COMMENT |
| LOW⚡ | sdks/python/examples/welcome_email/worker.py | 43 | # Step 1: Send the welcome email | COMMENT |
| LOW⚡ | sdks/python/examples/welcome_email/worker.py | 46 | # Step 2: Wait for the user to complete onboarding, or time out | COMMENT |
| LOW⚡ | sdks/python/examples/support_agent/worker.py | 135 | # Step 1: Triage the ticket | COMMENT |
| LOW⚡ | sdks/python/examples/support_agent/worker.py | 138 | # Step 2: Generate an initial reply | COMMENT |
| LOW⚡ | sdks/python/examples/support_agent/worker.py | 141 | # Step 3: Wait for a customer reply or timeout | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/welcome_email/workflow.ts | 28 | // Step 1: Send the welcome email | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/welcome_email/workflow.ts | 31 | // Step 2: Wait for the user to complete onboarding, or time out | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/support_agent/workflow.ts | 123 | // Step 1: Triage the ticket | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/support_agent/workflow.ts | 126 | // Step 2: Generate an initial reply | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/support_agent/workflow.ts | 129 | // Step 3: Wait for a customer reply or timeout | COMMENT |
| LOW | .claude/skills/build-tui-view/SKILL.md | 463 | #### Step 1: Create View File | COMMENT |
| LOW | .claude/skills/build-tui-view/SKILL.md | 533 | #### Step 2: Use View in TUI | COMMENT |
| LOW | .claude/skills/build-tui-view/SKILL.md | 1354 | #### Step 1: Create Debug Logger (if not exists) | COMMENT |
| LOW | .claude/skills/build-tui-view/SKILL.md | 1455 | #### Step 2: Integrate Debug Logger in Your View | COMMENT |
| LOW | .claude/skills/build-tui-view/SKILL.md | 1480 | #### Step 3: Add Debug Logging Throughout View | COMMENT |
| LOW | .claude/skills/build-tui-view/SKILL.md | 1502 | #### Step 4: Add Toggle Key Handler | COMMENT |
| LOW | .claude/skills/build-tui-view/SKILL.md | 1527 | #### Step 5: Implement Debug View Rendering | COMMENT |
| LOW | .claude/skills/build-tui-view/SKILL.md | 1608 | #### Step 6: Update Footer Controls | COMMENT |
| LOW | hack/dev/compression-test/README.md | 23 | ### Step 1: Build Baseline Images (Main Branch) | COMMENT |
| LOW | hack/dev/compression-test/README.md | 47 | ### Step 2: Build Compression Images (Current Branch) | COMMENT |
| LOW⚡ | examples/go/dag/main.go | 30 | // Step 1: Initial processing | COMMENT |
| LOW⚡ | examples/go/dag/main.go | 39 | // Step 2: Depends on step 1 | COMMENT |
| LOW | examples/go/dag/main.go | 54 | // Step 3: Also depends on step 1, parallel to step 2 | COMMENT |
| LOW | examples/go/opentelemetry_instrumentation/main.go | 208 | // Step 3: Send order confirmation (runs after both payment and inventory are done). | COMMENT |
| LOW⚡ | examples/go/with-workflows/main.go | 30 | // Step 1: Initial processing | COMMENT |
| LOW⚡ | examples/go/with-workflows/main.go | 38 | // Step 2: Depends on step 1 | COMMENT |
| LOW | examples/go/with-workflows/main.go | 52 | // Step 3: Also depends on step 1, parallel to step 2 | COMMENT |
| LOW⚡ | examples/python/welcome_email/worker.py | 42 | # Step 1: Send the welcome email | COMMENT |
| LOW⚡ | examples/python/welcome_email/worker.py | 45 | # Step 2: Wait for the user to complete onboarding, or time out | COMMENT |
| LOW⚡ | examples/python/support_agent/worker.py | 131 | # Step 1: Triage the ticket | COMMENT |
| 7 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | sdks/python/apply_patches.py | 43 | except Exception as e: | CODE |
| MEDIUM⚡ | sdks/python/apply_patches.py | 44 | print(f"Error patching {file_path}: {e}") | CODE |
| LOW | sdks/python/tests/worker_fixture.py | 43 | except Exception: | CODE |
| MEDIUM | sdks/python/tests/unit/test_durable_event_listener.py | 111 | def teardown(self) -> None: | CODE |
| LOW | sdks/python/tests/unit/test_durable_event_listener.py | 114 | except Exception: | CODE |
| LOW | sdks/python/tests/unit/test_durable_event_listener.py | 119 | except Exception: | CODE |
| LOW | sdks/python/tests/unit/test_instrumentor_signatures.py | 59 | except Exception: | CODE |
| LOW | sdks/python/tests/unit/test_instrumentor_signatures.py | 66 | except Exception: | CODE |
| LOW | sdks/python/tests/unit/test_shutdown_ordering.py | 269 | except Exception: | CODE |
| LOW | …failure_on_timeout_with_multi_concurrency/test_case.py | 44 | except Exception: | CODE |
| LOW | …pawn_cache_on_retry/test_child_spawn_cache_on_retry.py | 29 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/workflow_run.py | 114 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/clients/events.py | 170 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/clients/events.py | 415 | except Exception: | CODE |
| LOW | …ks/python/hatchet_sdk/clients/dispatcher/dispatcher.py | 151 | except Exception: | CODE |
| LOW | …ks/python/hatchet_sdk/clients/dispatcher/dispatcher.py | 284 | except Exception: | CODE |
| LOW | …thon/hatchet_sdk/clients/dispatcher/action_listener.py | 161 | except Exception: | CODE |
| LOW | …thon/hatchet_sdk/clients/dispatcher/action_listener.py | 215 | except Exception: | CODE |
| LOW | …thon/hatchet_sdk/clients/dispatcher/action_listener.py | 354 | except Exception: | CODE |
| LOW | …ython/hatchet_sdk/clients/listeners/pooled_listener.py | 155 | except Exception as e: | CODE |
| MEDIUM | …ython/hatchet_sdk/clients/listeners/pooled_listener.py | 99 | def _init_producer(self) -> None: | CODE |
| LOW⚡ | …atchet_sdk/clients/listeners/durable_event_listener.py | 448 | except Exception: | CODE |
| LOW⚡ | …atchet_sdk/clients/listeners/durable_event_listener.py | 454 | except Exception as e: | CODE |
| LOW⚡ | …atchet_sdk/clients/listeners/durable_event_listener.py | 461 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/clients/rest/exceptions.py | 132 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 500 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 559 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 577 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 597 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/opentelemetry/instrumentor.py | 100 | except Exception as exc: | CODE |
| LOW | sdks/python/hatchet_sdk/opentelemetry/instrumentor.py | 478 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/opentelemetry/instrumentor.py | 869 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/opentelemetry/instrumentor.py | 1178 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/opentelemetry/instrumentor.py | 1243 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/runnables/action.py | 116 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/runnables/workflow.py | 258 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/runnables/workflow.py | 1224 | except Exception as e: | CODE |
| MEDIUM | sdks/python/hatchet_sdk/worker/worker.py | 401 | def _setup_loop(self) -> None: | CODE |
| MEDIUM | sdks/python/hatchet_sdk/worker/worker.py | 639 | def _cleanup_lifespan(self) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 352 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 367 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 636 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 645 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 677 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 706 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 754 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 773 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 800 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 811 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 330 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 357 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 526 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 585 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 588 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 685 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 318 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 556 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 619 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 655 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 714 | except Exception as e: | CODE |
| 47 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | sdks/python/tests/worker_fixture.py | 135 | except (psutil.Error, OSError): | CODE |
| HIGH | sdks/python/tests/unit/test_durable_event_listener.py | 114 | except Exception: | CODE |
| HIGH | sdks/python/tests/unit/test_durable_event_listener.py | 119 | except Exception: | CODE |
| HIGH | …failure_on_timeout_with_multi_concurrency/test_case.py | 44 | except Exception: | CODE |
| HIGH | sdks/python/hatchet_sdk/embedded.py | 423 | except (OSError, ValidationError): | CODE |
| HIGH | sdks/python/hatchet_sdk/clients/rest/exceptions.py | 132 | except Exception: | CODE |
| HIGH | sdks/python/hatchet_sdk/opentelemetry/instrumentor.py | 117 | except ImportError: | CODE |
| HIGH | sdks/python/hatchet_sdk/worker/worker.py | 408 | except RuntimeError: | CODE |
| HIGH | sdks/python/hatchet_sdk/worker/worker.py | 773 | except Exception: | CODE |
| HIGH | sdks/python/examples/lifespans/test_lifespans.py | 56 | except psutil.NoSuchProcess: | CODE |
| HIGH | …oldest/test_concurrency_cancel_queued_except_oldest.py | 41 | except Exception: | CODE |
| HIGH | …oldest/test_concurrency_cancel_queued_except_oldest.py | 47 | except Exception: | CODE |
| HIGH | …cancel_queued_except_oldest_with_parent_concurrency.py | 42 | except Exception: | CODE |
| HIGH | …cancel_queued_except_oldest_with_parent_concurrency.py | 48 | except Exception: | CODE |
| HIGH | …rrency_cancel_newest/test_concurrency_cancel_newest.py | 44 | except Exception: | CODE |
| HIGH | …cancel_queued_except_newest_with_parent_concurrency.py | 47 | except Exception: | CODE |
| HIGH | …cancel_queued_except_newest_with_parent_concurrency.py | 53 | except Exception: | CODE |
| HIGH | …newest/test_concurrency_cancel_queued_except_newest.py | 40 | except Exception: | CODE |
| HIGH | …newest/test_concurrency_cancel_queued_except_newest.py | 46 | except Exception: | CODE |
| HIGH | …ask_level/test_concurrency_cancel_newest_task_level.py | 49 | except Exception: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 9 | // Step 1: Login as owner and create a tenant | COMMENT |
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 64 | // Step 2: Create an invite for the member user | COMMENT |
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 84 | // Step 4: Login as member (who has pending invite) | COMMENT |
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 108 | // Step 5: Decline all invites | COMMENT |
| LOW | …nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts | 141 | // Step 6: Verify the modal closes after all invites are declined | COMMENT |
| LOW⚡ | sdks/go/examples/dag/main.go | 31 | // Step 1: Initial processing | COMMENT |
| LOW⚡ | sdks/go/examples/dag/main.go | 41 | // Step 2: Depends on step 1 | COMMENT |
| LOW | sdks/go/examples/dag/main.go | 57 | // Step 3: Also depends on step 1, parallel to step 2 | COMMENT |
| LOW | sdks/go/examples/opentelemetry_instrumentation/main.go | 208 | // Step 3: Send order confirmation (runs after both payment and inventory are done). | COMMENT |
| LOW⚡ | sdks/go/examples/with-workflows/main.go | 30 | // Step 1: Initial processing | COMMENT |
| LOW⚡ | sdks/go/examples/with-workflows/main.go | 38 | // Step 2: Depends on step 1 | COMMENT |
| LOW | sdks/go/examples/with-workflows/main.go | 52 | // Step 3: Also depends on step 1, parallel to step 2 | COMMENT |
| LOW⚡ | sdks/python/examples/welcome_email/worker.py | 43 | # Step 1: Send the welcome email | COMMENT |
| LOW⚡ | sdks/python/examples/welcome_email/worker.py | 46 | # Step 2: Wait for the user to complete onboarding, or time out | COMMENT |
| LOW⚡ | sdks/python/examples/support_agent/worker.py | 135 | # Step 1: Triage the ticket | COMMENT |
| LOW⚡ | sdks/python/examples/support_agent/worker.py | 138 | # Step 2: Generate an initial reply | COMMENT |
| LOW⚡ | sdks/python/examples/support_agent/worker.py | 141 | # Step 3: Wait for a customer reply or timeout | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/welcome_email/workflow.ts | 28 | // Step 1: Send the welcome email | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/welcome_email/workflow.ts | 31 | // Step 2: Wait for the user to complete onboarding, or time out | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/support_agent/workflow.ts | 123 | // Step 1: Triage the ticket | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/support_agent/workflow.ts | 126 | // Step 2: Generate an initial reply | COMMENT |
| LOW⚡ | …s/typescript/src/v1/examples/support_agent/workflow.ts | 129 | // Step 3: Wait for a customer reply or timeout | COMMENT |
| LOW⚡ | examples/go/dag/main.go | 30 | // Step 1: Initial processing | COMMENT |
| LOW⚡ | examples/go/dag/main.go | 39 | // Step 2: Depends on step 1 | COMMENT |
| LOW | examples/go/dag/main.go | 54 | // Step 3: Also depends on step 1, parallel to step 2 | COMMENT |
| LOW | examples/go/opentelemetry_instrumentation/main.go | 208 | // Step 3: Send order confirmation (runs after both payment and inventory are done). | COMMENT |
| LOW⚡ | examples/go/with-workflows/main.go | 30 | // Step 1: Initial processing | COMMENT |
| LOW⚡ | examples/go/with-workflows/main.go | 38 | // Step 2: Depends on step 1 | COMMENT |
| LOW | examples/go/with-workflows/main.go | 52 | // Step 3: Also depends on step 1, parallel to step 2 | COMMENT |
| LOW⚡ | examples/python/welcome_email/worker.py | 42 | # Step 1: Send the welcome email | COMMENT |
| LOW⚡ | examples/python/welcome_email/worker.py | 45 | # Step 2: Wait for the user to complete onboarding, or time out | COMMENT |
| LOW⚡ | examples/python/support_agent/worker.py | 131 | # Step 1: Triage the ticket | COMMENT |
| LOW⚡ | examples/python/support_agent/worker.py | 134 | # Step 2: Generate an initial reply | COMMENT |
| LOW⚡ | examples/python/support_agent/worker.py | 137 | # Step 3: Wait for a customer reply or timeout | COMMENT |
| LOW⚡ | examples/typescript/welcome_email/workflow.ts | 27 | // Step 1: Send the welcome email | COMMENT |
| LOW⚡ | examples/typescript/welcome_email/workflow.ts | 30 | // Step 2: Wait for the user to complete onboarding, or time out | COMMENT |
| LOW⚡ | examples/typescript/support_agent/workflow.ts | 118 | // Step 1: Triage the ticket | COMMENT |
| LOW⚡ | examples/typescript/support_agent/workflow.ts | 121 | // Step 2: Generate an initial reply | COMMENT |
| LOW⚡ | examples/typescript/support_agent/workflow.ts | 124 | // Step 3: Wait for a customer reply or timeout | COMMENT |
| LOW | pkg/repository/task.go | 4051 | // we need to check if there are other steps in the subtree | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | sdks/python/apply_patches.py | 145 | # Check if already patched with HTTPMethod enum support | COMMENT |
| LOW | sdks/python/apply_patches.py | 369 | # Check if already using typed exceptions with HTTPMethod enum | STRING |
| LOW | sdks/python/tests/worker_fixture.py | 68 | # Check if the process is still running | COMMENT |
| LOW | sdks/ruby/src/spec/support/integration_helper.rb | 6 | # Check if integration tests should be run | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/clients.rb | 36 | # Check if REST client is available | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/clients.rb | 42 | # Check if this is the real implementation or just the placeholder | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/context.rb | 106 | # Check if a parent task was skipped | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/context.rb | 164 | # Check if the task has been cancelled | COMMENT |
| LOW | …atchet/clients/rest/lib/hatchet-sdk-rest/api_client.rb | 249 | # Check if the given MIME is a JSON MIME. | COMMENT |
| LOW⚡ | …het/clients/rest/lib/hatchet-sdk-rest/configuration.rb | 70 | # Set this to return data as binary instead of downloading a temp file. When enabled (set to true) | COMMENT |
| LOW⚡ | …het/clients/rest/lib/hatchet-sdk-rest/configuration.rb | 75 | # Set this to enable/disable debugging. When enabled (set to true), HTTP request/response | COMMENT |
| LOW⚡ | …het/clients/rest/lib/hatchet-sdk-rest/configuration.rb | 82 | # Set this to ignore operation servers for the API client. This is useful when you need to | COMMENT |
| LOW | …het/clients/rest/lib/hatchet-sdk-rest/configuration.rb | 107 | # Set this to false to skip client side validation in the operation. | COMMENT |
| LOW | …het/clients/rest/lib/hatchet-sdk-rest/configuration.rb | 113 | # Set this to false to skip verifying SSL certificate when calling API from https server. | COMMENT |
| LOW | …het/clients/rest/lib/hatchet-sdk-rest/configuration.rb | 129 | # Set this to customize the certificate file to verify the peer. | COMMENT |
| LOW | …het/clients/rest/lib/hatchet-sdk-rest/configuration.rb | 146 | # Set this to customize parameters encoder of array parameter. | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/features/runs.rb | 577 | # Check if a workflow run status is terminal (completed) | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/worker/health_check.rb | 81 | # Check if the server is running | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/worker/action_listener.rb | 97 | # Check if connection was healthy long enough to reset retries | COMMENT |
| LOW | hack/install/install.sh | 63 | # Set trap to cleanup on exit | COMMENT |
| LOW | hack/install/install.sh | 149 | # Check if INSTALL_DIR is already set via environment variable | COMMENT |
| LOW | hack/install/install.sh | 162 | # Check if ~/.local/bin is in PATH and is/can be writable | COMMENT |
| LOW | hack/install/install.sh | 183 | # Check if we'll need sudo | COMMENT |
| LOW | hack/install/install.sh | 338 | # Check if we need sudo | COMMENT |
| LOW | hack/dev/start-dev-tmux.sh | 7 | # Check if tmux is installed | COMMENT |
| LOW | hack/dev/compression-test/scripts/run_test.sh | 53 | # Check if client image exists | COMMENT |
| LOW | hack/dev/compression-test/scripts/monitor_network.sh | 100 | # Check if we got valid stats (not empty and not just "0B / 0B") | COMMENT |
| LOW | hack/dev/compression-test/scripts/monitor_network.sh | 165 | # Check if container still exists - if not, break early but still write summary | COMMENT |
| LOW | hack/dev/compression-test/scripts/monitor_network.sh | 183 | # Check if container exists (running or stopped) | COMMENT |
| LOW | hack/dev/compression-test/scripts/monitor_network.sh | 212 | # Check if bc is available, if not use awk for calculations | COMMENT |
| LOW | .github/workflows/gen-examples.yml | 41 | # Check if there are any changes | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | cmd/hatchet-admin/cli/seed/seed-cypress.go | 59 | email: "admin@example.com", | CODE |
| LOW | cmd/hatchet-cli/cli/embedded_ui_session.go | 23 | defaultSeedAdminEmail = "admin@example.com" | CODE |
| LOW | cmd/hatchet-cli/cli/server.go | 221 | lines = append(lines, styles.Muted.Render("Admin credentials: email 'admin@example.com', password 'Admin123!!'")) | CODE |
| LOW | cmd/hatchet-cli/cli/embedded_ui_session_test.go | 50 | if body.Email != "admin@example.com" || body.Password != "Admin123!!" { | CODE |
| LOW | cmd/hatchet-cli/cli/embedded_ui_session_test.go | 59 | _, _ = w.Write([]byte(`{"email":"admin@example.com"}`)) | CODE |
| LOW | cmd/hatchet-cli/cli/embedded_ui_session_test.go | 108 | return adminCredentials{email: "admin@example.com", password: "Admin123!!", isDefault: true} | CODE |
| LOW | frontend/app/src/lib/free-email-domains.json | 937 | "fake-email.pp.ua", | CODE |
| LOW | …ain/v1/workflow-runs-v1/$run/v2components/mini-map.tsx | 48 | const node = shapeItem.stepId ?? 'placeholder'; | CODE |
| LOW | sdks/go/examples/events/main.go | 58 | "email": "user@example.com", | CODE |
| LOW | sdks/go/examples/events/main.go | 59 | "name": "John Doe", | CODE |
| LOW | sdks/go/examples/events/main.go | 73 | "name": "John Doe", | CODE |
| LOW | sdks/python/examples/cron/programatic-async.py | 21 | input=DynamicCronInput(name="John Doe"), | CODE |
| LOW | sdks/python/examples/cron/programatic-sync.py | 20 | input=DynamicCronInput(name="John Doe"), | CODE |
| LOW | …egacy/examples/scheduled-runs/programatic-schedules.ts | 17 | name: 'John Doe', | CODE |
| LOW | …escript/src/legacy/examples/crons/programatic-crons.ts | 18 | name: 'John Doe', | CODE |
| LOW | sdks/ruby/examples/cron/programatic_sync.rb | 13 | input: { "name" => "John Doe" } | CODE |
| LOW | sdks/ruby/src/lib/hatchet/features/events.rb | 85 | # { user_id: 456, email: "user@example.com" }, | COMMENT |
| LOW | examples/go/guides/human-in-the-loop/main.go | 45 | proposedAction := map[string]string{"action": "send_email", "to": "user@example.com"} | CODE |
| LOW | examples/go/events/main.go | 58 | "email": "user@example.com", | CODE |
| LOW | examples/go/events/main.go | 59 | "name": "John Doe", | CODE |
| LOW | examples/go/events/main.go | 73 | "name": "John Doe", | CODE |
| LOW | examples/python/cron/programatic-async.py | 21 | input=DynamicCronInput(name="John Doe"), | CODE |
| LOW | examples/python/cron/programatic-sync.py | 20 | input=DynamicCronInput(name="John Doe"), | CODE |
| LOW | examples/ruby/guides/human_in_the_loop/worker.rb | 23 | proposed_action = { 'action' => 'send_email', 'to' => 'user@example.com' } | CODE |
| LOW | examples/ruby/cron/programatic_sync.rb | 13 | input: { "name" => "John Doe" } | CODE |
| LOW | pkg/config/database/config.go | 60 | AdminEmail string `mapstructure:"adminEmail" json:"adminEmail,omitempty" default:"admin@example.com"` | CODE |
| LOW⚡ | pkg/integrations/email/smtp/smtp_test.go | 43 | expectedRecipients: []string{"user@example.com"}, | CODE |
| LOW⚡ | pkg/integrations/email/smtp/smtp_test.go | 45 | TenantName: "Acme Corp", | CODE |
| LOW⚡ | pkg/integrations/email/smtp/smtp_test.go | 51 | ctx, "user@example.com", d.(email.TenantInviteEmailData), | CODE |
| LOW⚡ | pkg/integrations/email/smtp/smtp_test.go | 61 | TenantName: "Acme Corp", | CODE |
| LOW⚡ | pkg/integrations/email/smtp/smtp_test.go | 76 | expectedRecipients: []string{"admin@example.com"}, | CODE |
| LOW⚡ | pkg/integrations/email/smtp/smtp_test.go | 78 | TenantName: "Acme Corp", | CODE |
| LOW⚡ | pkg/integrations/email/smtp/smtp_test.go | 87 | ctx, []string{"admin@example.com"}, d.(email.ExpiringTokenEmailData), | CODE |
| LOW⚡ | pkg/integrations/email/smtp/smtp_test.go | 96 | expectedRecipients: []string{"admin@example.com", testSupportEmail}, | CODE |
| LOW⚡ | pkg/integrations/email/smtp/smtp_test.go | 98 | TenantName: "Acme Corp", | CODE |
| LOW | pkg/integrations/email/smtp/smtp_test.go | 109 | ctx, []string{"admin@example.com"}, d.(email.ResourceLimitAlertData), | CODE |
| LOW | pkg/integrations/email/smtp/smtp_test.go | 156 | err := service.SendTenantInviteEmail(context.Background(), "user@example.com", email.TenantInviteEmailData{ | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | frontend/snippets/generate.py | 189 | CODE | |
| LOW | frontend/snippets/generate.py | 235 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/admin.py | 414 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/admin.py | 459 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/admin.py | 533 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/admin.py | 607 | CODE | |
| LOW | …thon/hatchet_sdk/clients/dispatcher/action_listener.py | 78 | CODE | |
| LOW | …thon/hatchet_sdk/clients/dispatcher/action_listener.py | 152 | CODE | |
| LOW | …on/hatchet_sdk/clients/listeners/run_event_listener.py | 148 | CODE | |
| LOW | …ython/hatchet_sdk/clients/listeners/pooled_listener.py | 99 | CODE | |
| LOW | …atchet_sdk/clients/listeners/durable_event_listener.py | 413 | CODE | |
| LOW | …atchet_sdk/clients/listeners/durable_event_listener.py | 464 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/rest.py | 120 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api_client.py | 272 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api_client.py | 330 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api_client.py | 430 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api_client.py | 475 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api_client.py | 504 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api_client.py | 543 | CODE | |
| LOW | sdks/python/hatchet_sdk/runnables/task.py | 325 | CODE | |
| LOW | sdks/python/hatchet_sdk/runnables/task.py | 370 | CODE | |
| LOW | sdks/python/hatchet_sdk/runnables/task.py | 423 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 681 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 757 | CODE | |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 459 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 504 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 695 | CODE | |
| LOW | …python/hatchet_sdk/worker/runner/utils/capture_logs.py | 89 | CODE | |
| LOW | sdks/python/hatchet_sdk/deprecated/worker.py | 224 | CODE | |
| LOW | …thon/hatchet_sdk/deprecated/action_listener_process.py | 348 | CODE | |
| LOW | sdks/python/examples/pdf_pipeline/worker.py | 105 | CODE | |
| LOW | …ment/test_worker_shutdown_no_premature_reassignment.py | 29 | CODE | |
| LOW | hack/db/generate-oss-db-model.py | 97 | CODE | |
| LOW | hack/db/generate-oss-db-model.py | 132 | CODE | |
| LOW | hack/db/generate-oss-db-model.py | 171 | CODE | |
| LOW | examples/python/pdf_pipeline/worker.py | 102 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | README.md | 9 | ### An orchestration engine for background tasks, AI agents, and durable workflows | COMMENT |
| MEDIUM | README.md | 64 | #### Task orchestration and workflows | COMMENT |
| MEDIUM | …pages/main/v1/overview/components/onboarding-steps.tsx | 226 | // The persisted manual-path template (one the CLI can scaffold). | COMMENT |
| MEDIUM | frontend/docs/guides/STEP_SCHEMA.md | 30 | ## event-driven | COMMENT |
| MEDIUM | frontend/docs/guides/STEP_SCHEMA.md | 76 | ## multi-agent | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet-sdk.rb | 117 | # event-driven workflows. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/events.rb | 44 | # processed and made available for workflow triggers and event-driven automation. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | sdks/python/docs/generator/generate.py | 351 | def update_readme_agent_docs() -> None: | CODE |
| LOW | sdks/python/docs/generator/generate.py | 406 | def update_meta_json(documents: list[Document]) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/labels.py | 3 | __all__ = ["DesiredWorkerLabel", "WorkerLabel"] | CODE |
| LOW | sdks/python/hatchet_sdk/__init__.py | 207 | __all__ = [ | CODE |
| LOW | sdks/python/hatchet_sdk/rate_limit.py | 3 | __all__ = ["RateLimit", "RateLimitDuration"] | CODE |
| LOW | sdks/python/hatchet_sdk/clients/rest/configuration.py | 361 | def set_default(cls, default: Optional[Self]) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/types/__init__.py | 15 | __all__ = [ | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 417 | def _set_cancellation_flag(self) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/utils/priority.py | 3 | __all__ = ["Priority", "_warn_if_int_priority"] | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 401 | def _setup_loop(self) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 709 | def _setup_signal_handlers(self) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/slot_types.py | 3 | __all__ = ["SlotType"] | CODE |
| LOW | …python/hatchet_sdk/worker/durable_eviction/__init__.py | 8 | __all__ = [ | CODE |
| LOW | sdks/python/hatchet_sdk/serde/__init__.py | 6 | __all__ = [ | CODE |
| LOW | sdks/python/examples/logger/workflow.py | 9 | logger = logging.getLogger(__name__) | CODE |
| LOW | examples/python/logger/workflow.py | 9 | logger = logging.getLogger(__name__) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | sdks/go/client.go | 971 | // Example usage: | COMMENT |
| LOW | sdks/go/client.go | 1010 | // Example usage: | COMMENT |
| LOW | sdks/ruby/generate.sh | 9 | # Usage: | COMMENT |
| LOW | hack/update-go-quickstart-deps.sh | 22 | # Usage: | COMMENT |
| LOW | hack/install/install.sh | 6 | # Usage: | COMMENT |
| LOW | hack/ci/pgstat-sampler.sh | 8 | # Usage: | COMMENT |
| LOW | hack/ci/pprof-sampler.sh | 7 | # Usage: | COMMENT |
| LOW | hack/ci/cpu-sampler.sh | 9 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | sdks/go/examples/webhooks/main.go | 167 | APIKey: "your-api-key", | CODE |
| HIGH | examples/go/webhooks/main.go | 162 | APIKey: "your-api-key", | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | sdks/python/hatchet_sdk/runnables/workflow.py | 2582 | wrr = self._workflow.client._client.runs.get_run_ref(run_id) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | sdks/ruby/src/lib/hatchet-sdk.rb | 116 | # The events client, which you can use to push events to Hatchet to trigger | COMMENT |
| MEDIUM | …/ruby/src/lib/hatchet/clients/rest/spec/spec_helper.rb | 59 | # with RSpec, but feel free to customize to your heart's content. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …/pages/main/v1/managed-workers/demo-template/index.tsx | 307 | print(result) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ython/examples/opentelemetry_instrumentation/worker.py | 76 | def process_data(input: EmptyModel, ctx: Context) -> ProcessDataOutput: | CODE |
| LOW | examples/python/opentelemetry_instrumentation/worker.py | 76 | def process_data(input: EmptyModel, ctx: Context) -> ProcessDataOutput: | CODE |