🪓 An orchestration engine for background tasks, AI agents, and durable workflows
This report presents the forensic synthetic code analysis of hatchet-dev/hatchet, a Go project with 7,807 GitHub stars. SynthScan v2.0 examined 779,976 lines of code across 3990 source files, recording 4663 pattern matches distributed across 23 syntactic categories. The overall adjusted score of 11.5 places this repository in the Low AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 4663 distinct pattern matches across 23 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. 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 diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| 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 |
| 870 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | frontend/app/src/query-client.tsx | 21 | function setupExchangeTokenRefreshTriggers() { | CODE |
| LOW | frontend/app/src/router.tsx | 410 | async function getOrganizationIdForTenantInRouter(tenantId: string) { | CODE |
| LOW | frontend/app/src/components/v1/ui/chart.tsx | 317 | 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 | …d/app/src/components/v1/cloud/billing/subscription.tsx | 89 | function getPlanChangeErrorMessage(error: unknown) { | CODE |
| LOW | …/components/v1/cloud/billing/subscription-plan-code.ts | 3 | export function resolveSubscriptionPlanCode( | CODE |
| LOW | …nents/forms/organization-onboarding-questions-form.tsx | 48 | export function OrganizationOnboardingQuestionsForm({ | CODE |
| LOW | …app/src/components/sso/SsoDeleteConfirmationDialog.tsx | 13 | export function SsoDeleteConfirmationDialog() { | CODE |
| LOW | frontend/app/src/lib/breadcrumbs.ts | 155 | 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/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/billing.tsx | 129 | function OrganizationBillingContent() { | CODE |
| LOW | …c/pages/main/v1/tenant-settings/organization/index.tsx | 244 | 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 | 33 | export function PrometheusMetricsSettings() { | CODE |
| LOW | …ntegrations/components/prometheus-metrics-settings.tsx | 178 | 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 | 252 | 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 | 528 | 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 |
| LOW | sdks/python/conftest.py | 78 | def _on_demand_worker_fixture( | CODE |
| LOW⚡ | sdks/python/apply_patches.py | 54 | def patch_contract_import_paths(content: str) -> str: | CODE |
| LOW⚡ | sdks/python/apply_patches.py | 62 | def patch_grpc_dispatcher_import(content: str) -> str: | CODE |
| LOW | sdks/python/apply_patches.py | 78 | def patch_grpc_workflows_import(content: str) -> str: | CODE |
| LOW | sdks/python/apply_patches.py | 86 | def patch_grpc_init_signature(content: str) -> str: | CODE |
| LOW | sdks/python/apply_patches.py | 138 | def patch_rest_transport_exceptions(content: str) -> str: | CODE |
| LOW | sdks/python/apply_patches.py | 332 | def patch_rest_error_diagnostics(content: str) -> str: | STRING |
| LOW | sdks/python/apply_patches.py | 560 | def apply_patches_to_matching_files( | STRING |
| LOW | sdks/python/apply_patches.py | 567 | def patch_api_client_datetime_format_on_post(content: str) -> str: | STRING |
| 1086 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_capture_logs.py | 5 | 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 | 13 | 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 | |
| 1278 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 | 61 | // ── Queries ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/organization-wrapper.ts | 144 | // ── Mutations ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/organization-wrapper.ts | 391 | // ── 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 |
| 79 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 | …het-sdk-rest/models/v1_update_http_operator_request.rb | 233 | # 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 | …t/lib/hatchet-sdk-rest/models/v1_http_operator_list.rb | 212 | # 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 | …het-sdk-rest/models/v1_create_http_operator_request.rb | 327 | # 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 | …/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 |
| 144 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/quickstart_e2e_test.go | 21 | useCase string | 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 | 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 | frontend/app/src/pages/main/v1/overview/index.tsx | 221 | const hasConnectedWorker = hasQualifiedWorker( | 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/client.go | 701 | // | COMMENT |
| LOW | sdks/go/client.go | 741 | task := workflow.NewBatchTask(name, fn, batch, taskOptions...) | COMMENT |
| LOW | sdks/go/client.go | 881 | COMMENT | |
| LOW | sdks/go/deprecation.go | 41 | COMMENT | |
| LOW | sdks/go/workflow.go | 601 | // NewBatchTask transforms a function into a Hatchet batch task that runs as part of a | 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/delayed/test_delayed.py | 1 | # from hatchet_sdk import Hatchet | 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 | sdks/typescript/src/v1/declaration.ts | 821 | // pause() { | COMMENT |
| LOW | sdks/typescript/src/v1/client/features/workflows.ts | 161 | throw error; | COMMENT |
| LOW | sdks/typescript/src/v1/client/features/workflows.ts | 181 | // const { data } = await this.api.workflowUpdate(workflowObj.metadata.id, { | COMMENT |
| LOW | sdks/typescript/src/v1/client/features/workflows.ts | 201 | // async unpause(workflow: string | WorkflowDeclaration<any, any> | Workflow) { | COMMENT |
| LOW | sdks/typescript/src/v1/client/features/workflows.ts | 221 | // }); | 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/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 |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 221 | # Create a standalone Hatchet task. The task is automatically wrapped in a | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 241 | wf.task(name, **opts, &block) | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 261 | # batch = hatchet.batch_task(name: "my_batch", batch: Hatchet::BatchTaskConfig.new(max_size: 3)) do |inputs, ctx| | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 281 | wf = Workflow.new(name: name, client: self, | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 341 | # @return [Hatchet::Clients::Grpc::EventClient] | COMMENT |
| 243 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 | 377 | hatchet.event.push(EVENT_KEY, {"order": "first"}, scope=scope) | CODE |
| HIGH⚡ | sdks/python/examples/durable/test_durable.py | 389 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 140 | hatchet.event.push(EVENT_KEY, {"test": "test"}) | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 357 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 402 | hatchet.event.push("key1", {"order": "first"}, scope=scope) | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 421 | 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 | 190 | hatchet.event.push(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 | 337 | # Create a trap to kill the watcher when the task exits | COMMENT |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 38 | # Create a new profile (interactive) | COMMENT |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 41 | # Create a new profile (non-interactive) | COMMENT |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 78 | Example: ` # Create a new profile interactively (prompts for token) | CODE |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 81 | # 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/operator_api.rb | 22 | # Create an HTTP operator | COMMENT |
| MEDIUM⚡ | …/clients/rest/lib/hatchet-sdk-rest/api/operator_api.rb | 23 | # Create a new HTTP operator | COMMENT |
| MEDIUM⚡ | …/clients/rest/lib/hatchet-sdk-rest/api/operator_api.rb | 33 | # Create an HTTP operator | COMMENT |
| MEDIUM⚡ | …/clients/rest/lib/hatchet-sdk-rest/api/operator_api.rb | 34 | # Create a new HTTP operator | 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 |
| 14 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | sdks/python/hatchet_sdk/hatchet.py | 313 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 337 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 360 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 439 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 475 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 510 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 658 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 690 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 722 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 754 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 788 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 924 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 960 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 999 | 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 | |
| 80 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 10 | ## Step 1: Write Input to a Temp File | COMMENT |
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 23 | ## Step 2: Trigger the Workflow | COMMENT |
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 31 | ## Step 3: Poll for Completion | COMMENT |
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 45 | ## Step 4: Handle Failure | COMMENT |
| LOW | …ill-assets/hatchet-cli/references/trigger-and-watch.md | 65 | ## 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: Check for Existing Profiles | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/setup-cli.md | 45 | ## Step 4: Create a Profile | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/setup-cli.md | 61 | ## Step 5: Verify Connectivity | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/debug-run.md | 5 | ## Step 1: Get Run State | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/debug-run.md | 19 | ## Step 2: Get Event Log | COMMENT |
| LOW | …i/cli/skill-assets/hatchet-cli/references/debug-run.md | 34 | ## Step 3: Get Logs | COMMENT |
| LOW | …/cli/skill-assets/hatchet-cli/references/replay-run.md | 5 | ## Step 1: Inspect the Original Run | COMMENT |
| LOW | …/cli/skill-assets/hatchet-cli/references/replay-run.md | 55 | ## Step 3: Watch the New Run | 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 |
| 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 |
| 4 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 | 42 | 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 | 94 | 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 | 150 | except Exception: | CODE |
| LOW | …ks/python/hatchet_sdk/clients/dispatcher/dispatcher.py | 280 | 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 | 381 | except Exception: | CODE |
| LOW⚡ | …atchet_sdk/clients/listeners/durable_event_listener.py | 387 | except Exception as e: | CODE |
| LOW⚡ | …atchet_sdk/clients/listeners/durable_event_listener.py | 394 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/clients/rest/exceptions.py | 132 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 499 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 558 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 576 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 596 | 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 | 115 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/runnables/workflow.py | 251 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/runnables/workflow.py | 1217 | except Exception as e: | CODE |
| MEDIUM | sdks/python/hatchet_sdk/worker/worker.py | 388 | def _setup_loop(self) -> None: | CODE |
| MEDIUM | sdks/python/hatchet_sdk/worker/worker.py | 593 | def _cleanup_lifespan(self) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 342 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 353 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 590 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 599 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 630 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 659 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 707 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 726 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 753 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 764 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 288 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 315 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 456 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 515 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 518 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 614 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 288 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 522 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 583 | 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 | 674 | except Exception as e: | CODE |
| 40 more matches not shown… | ||||
| 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 | 3690 | // 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 | 67 | # 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 | 39 | # 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/server.go | 221 | lines = append(lines, styles.Muted.Render("Admin credentials: email 'admin@example.com', password 'Admin123!!'")) | 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 | 59 | 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 | 532 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/admin.py | 606 | 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 | 346 | CODE | |
| LOW | …atchet_sdk/clients/listeners/durable_event_listener.py | 397 | 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 | 324 | CODE | |
| LOW | sdks/python/hatchet_sdk/runnables/task.py | 369 | CODE | |
| LOW | sdks/python/hatchet_sdk/runnables/task.py | 422 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 634 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 710 | CODE | |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 390 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 472 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 655 | CODE | |
| LOW | …python/hatchet_sdk/worker/runner/utils/capture_logs.py | 87 | 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 | 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 | 137 | 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 | 206 | __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 | 416 | 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 | 388 | def _setup_loop(self) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 662 | 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 |
|---|---|---|---|---|
| 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 | 2567 | wrr = self._workflow.client._client.runs.get_run_ref(run_id) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | sdks/go/client.go | 885 | // Example usage: | COMMENT |
| LOW | sdks/go/client.go | 924 | // 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 |
| 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 |