🪓 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,505 GitHub stars. SynthScan v2.0 examined 700,795 lines of code across 3689 source files, recording 4255 pattern matches distributed across 23 syntactic categories. The overall adjusted score of 11.7 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 4255 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 | 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 | …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 |
| HIGH | …atchet_sdk/clients/rest/models/workflow_concurrency.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 | …rest/models/update_tenant_alert_email_group_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 |
| 841 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 | 419 | 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 | 249 | function nestChildWorkflowRunsUnderProducers(nodes: OtelSpanTree[]): void { | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 286 | function suppressStandaloneQueuedSpans(nodes: OtelSpanTree[]): void { | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 294 | function synthesizeInProgressSpans( | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 406 | function suppressOrphanedChildWorkflows( | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 478 | function synthesizePendingTaskSpans( | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 569 | function attachWorkflowQueuedPhase( | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 741 | function computeDurationFromChildren(node: OtelSpanTree): void { | CODE |
| LOW | …t-prism/convert-otel-spans-to-agent-prism-span-tree.ts | 791 | 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 | …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 | 24 | export function exchangeTokenQueryOptions( | CODE |
| LOW | frontend/app/src/lib/api/api.ts | 114 | export function resolveExchangeTokenTenantId( | CODE |
| LOW | frontend/app/src/lib/api/api.ts | 147 | async function resolveControlPlaneEnabled(): Promise<boolean> { | CODE |
| LOW | …/app/src/pages/organizations/$organization/billing.tsx | 130 | function OrganizationBillingContent() { | CODE |
| LOW | …c/pages/main/v1/tenant-settings/organization/index.tsx | 241 | export function CloudOrganizationSettings({ | CODE |
| LOW | …ng/components/update-tenant-alerting-settings-form.tsx | 33 | 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 | …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 | 249 | 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 | 406 | function TriggeringParentWorkflowRunSection({ | CODE |
| LOW | …d-worker/components/managed-worker-instances-table.tsx | 17 | export function ManagedWorkerInstancesTable({ | CODE |
| LOW | frontend/docs/scripts/generate-llms.ts | 558 | function resolveMdxComponentImports( | CODE |
| LOW | frontend/docs/lib/docs-languages.ts | 41 | export function getFixedPackageManagerMessage(lang: DocLanguage): string | null { | 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 | 63 | 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 |
| LOW | sdks/python/apply_patches.py | 585 | def patch_workflow_run_metrics_counts_return_type(content: str) -> str: | STRING |
| LOW | sdks/python/apply_patches.py | 611 | def patch_workflows_pyi_reexport(content: str) -> str: | STRING |
| 986 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/conftest.py | 4 | CODE | |
| LOW | sdks/python/tests/unit/test_aio_put_stream.py | 1 | CODE | |
| LOW | sdks/python/tests/unit/test_capture_logs.py | 1 | CODE | |
| LOW | sdks/python/tests/unit/test_shutdown_ordering.py | 3 | CODE | |
| LOW | …ks/python/tests/unit/test_batch_run_instrumentation.py | 8 | CODE | |
| LOW | sdks/python/tests/unit/test_durable_eviction_manager.py | 1 | CODE | |
| LOW | …failure_on_timeout_with_multi_concurrency/test_case.py | 8 | CODE | |
| LOW | sdks/python/tests/child_spawn_cache_on_retry/worker.py | 4 | CODE | |
| LOW | …pawn_cache_on_retry/test_child_spawn_cache_on_retry.py | 7 | CODE | |
| LOW | sdks/python/hatchet_sdk/labels.py | 1 | CODE | |
| LOW | sdks/python/hatchet_sdk/labels.py | 1 | CODE | |
| LOW | sdks/python/hatchet_sdk/workflow_run.py | 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 | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 80 | CODE | |
| LOW | sdks/python/hatchet_sdk/__init__.py | 81 | CODE | |
| 1207 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 | …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 | 562 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …chet-sdk-rest/models/v1_create_webhook_request_base.rb | 315 | # 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 | …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 | 222 | # 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 | 325 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …est/lib/hatchet-sdk-rest/models/list_slack_webhooks.rb | 246 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …rest/lib/hatchet-sdk-rest/models/user_login_request.rb | 246 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …clients/rest/lib/hatchet-sdk-rest/models/event_data.rb | 219 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ents/rest/lib/hatchet-sdk-rest/models/slack_webhook.rb | 353 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …atchet-sdk-rest/models/user_change_password_request.rb | 246 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ib/hatchet-sdk-rest/models/scheduled_workflows_list.rb | 212 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …chet-sdk-rest/models/v1_create_webhook_request_hmac.rb | 377 | # 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 | 327 | # 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 | 377 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ts/rest/lib/hatchet-sdk-rest/models/v1_task_summary.rb | 793 | # 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 | …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 | …s/rest/lib/hatchet-sdk-rest/models/workflow_version.rb | 394 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …rest/lib/hatchet-sdk-rest/models/worker_slot_config.rb | 230 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …tchet-sdk-rest/models/tenant_step_run_queue_metrics.rb | 201 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …ents/rest/lib/hatchet-sdk-rest/models/tenant_member.rb | 304 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …clients/rest/lib/hatchet-sdk-rest/models/rate_limit.rb | 354 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …t/lib/hatchet-sdk-rest/models/list_sns_integrations.rb | 246 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …chet-sdk-rest/models/webhook_worker_create_response.rb | 201 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| LOW | …/hatchet-sdk-rest/models/workflow_trigger_event_ref.rb | 210 | # For object, use to_hash. Otherwise, just return the value | COMMENT |
| 120 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| 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 | // if (!workflow.scheduleTimeout) { | 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 | frontend/docs/next-env.d.ts | 1 | /// <reference types="next" /> | COMMENT |
| LOW | sdks/go/hatchet.go | 1 | // Define workflows that can declare tasks and be run, scheduled, and so on. | COMMENT |
| LOW | sdks/go/hatchet.go | 21 | // | COMMENT |
| LOW | sdks/go/hatchet.go | 41 | // - Nested workflow execution: https://github.com/hatchet-dev/hatchet/tree/main/sdks/go/examples/child-workflows | COMMENT |
| LOW | sdks/go/hatchet.go | 101 | // EventInto extracts the event payload from a WaitForEvent result into dest. | COMMENT |
| LOW | sdks/go/client.go | 661 | // NewStandaloneDurableTask creates a standalone durable task that can be triggered independently. | COMMENT |
| LOW | sdks/go/client.go | 781 | result any | COMMENT |
| LOW | sdks/go/deprecation.go | 41 | 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 | 781 | } | 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/src/lib/hatchet-sdk.rb | 81 | # | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 101 | # Initialize a new Hatchet client with the given configuration options. | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 201 | # @example | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 241 | COMMENT | |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 281 | # gRPC Admin client (lazy-initialized). | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet-sdk.rb | 321 | @client = client | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/worker_obj.rb | 1 | # frozen_string_literal: true | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/context_vars.rb | 1 | # frozen_string_literal: true | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/workflow.rb | 1 | # frozen_string_literal: true | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/workflow.rb | 41 | attr_reader :client | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/durable_context.rb | 1 | # frozen_string_literal: true | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/durable_context.rb | 21 | # @example Wait for an event | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/clients.rb | 21 | # @param config [Hatchet::Config] The main Hatchet configuration | COMMENT |
| 196 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | Taskfile.yaml | 301 | # Create a trap to kill the watcher when the task exits | COMMENT |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 36 | # Create a new profile (interactive) | COMMENT |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 39 | # Create a new profile (non-interactive) | COMMENT |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 76 | Example: ` # Create a new profile interactively (prompts for token) | CODE |
| MEDIUM | cmd/hatchet-cli/cli/profile.go | 79 | # 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 | 298 | # 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 | 195 | # Create a new workflow definition | COMMENT |
| MEDIUM⚡ | sdks/ruby/src/lib/hatchet-sdk.rb | 208 | # Create a standalone task (auto-wraps in a single-task workflow) | COMMENT |
| MEDIUM⚡ | sdks/ruby/src/lib/hatchet-sdk.rb | 218 | # Create a workflow wrapper for standalone tasks | COMMENT |
| MEDIUM⚡ | sdks/ruby/src/lib/hatchet-sdk.rb | 225 | # Create a standalone durable task. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet-sdk.rb | 242 | # Create a new worker | 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 | 95 | # Define a task within this workflow | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 113 | # Define a durable task within this workflow. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 127 | # Define an on_failure task for this workflow | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 142 | # Define an on_success task for this workflow | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 257 | # Create a bulk run item for use with run_many | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/workflow.rb | 282 | # Create a cron trigger for this workflow | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/durable_context.rb | 185 | # 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 | 254 | # Create a bulk run item for use with run_many | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/clients/rest.rb | 26 | # Create a Configuration instance from a Hatchet::Config | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/clients/rest/.rubocop.yml | 1 | # This file is based on https://github.com/rails/rails/blob/master/.rubocop.yml (MIT license) | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/clients/rest/.rubocop.yml | 87 | # Defining a method with parameters needs parentheses. | COMMENT |
| MEDIUM⚡ | …et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb | 22 | # Create a filter | COMMENT |
| MEDIUM⚡ | …et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb | 23 | # Create a new filter | COMMENT |
| MEDIUM⚡ | …et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb | 33 | # Create a filter | COMMENT |
| MEDIUM⚡ | …et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb | 34 | # Create a new filter | COMMENT |
| MEDIUM⚡ | …t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb | 22 | # Create a webhook | COMMENT |
| MEDIUM⚡ | …t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb | 23 | # Create a new webhook | COMMENT |
| MEDIUM⚡ | …t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb | 33 | # Create a webhook | COMMENT |
| MEDIUM⚡ | …t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb | 34 | # Create a new webhook | COMMENT |
| MEDIUM⚡ | …ents/rest/lib/hatchet-sdk-rest/api/workflow_run_api.rb | 23 | # Create a new cron job workflow trigger for a tenant | COMMENT |
| MEDIUM⚡ | …ents/rest/lib/hatchet-sdk-rest/api/workflow_run_api.rb | 35 | # Create a new cron job workflow trigger for a tenant | COMMENT |
| MEDIUM | …t/clients/rest/lib/hatchet-sdk-rest/api/default_api.rb | 331 | # Create a webhook | COMMENT |
| MEDIUM | …t/clients/rest/lib/hatchet-sdk-rest/api/default_api.rb | 342 | # Create a webhook | COMMENT |
| MEDIUM | …clients/rest/lib/hatchet-sdk-rest/api/api_token_api.rb | 23 | # Create an API token for a tenant | COMMENT |
| MEDIUM | …clients/rest/lib/hatchet-sdk-rest/api/api_token_api.rb | 34 | # Create an API token for a tenant | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/filters.rb | 7 | # This class provides a high-level interface for creating, retrieving, | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/filters.rb | 67 | # Create a new filter | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/rate_limits.rb | 7 | # This class provides a high-level interface for creating and updating | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/workers.rb | 7 | # This class provides a high-level interface for retrieving, listing, and | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/runs.rb | 70 | # This class provides a high-level interface for creating and managing workflow runs | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/runs.rb | 282 | # This method is intended to be an escape hatch. | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/runs.rb | 369 | # This method provides an easy way to perform bulk replay operations by filters | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/runs.rb | 398 | # This method provides an easy way to perform bulk cancel operations by filters | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/scheduled.rb | 9 | # This class provides a high-level interface for creating, deleting, | COMMENT |
| MEDIUM | sdks/ruby/src/lib/hatchet/features/scheduled.rb | 35 | # Create a new scheduled workflow run | COMMENT |
| 9 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 | 375 | hatchet.event.push(EVENT_KEY, {"order": "first"}, scope=scope) | CODE |
| HIGH⚡ | sdks/python/examples/durable/test_durable.py | 387 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 138 | hatchet.event.push(EVENT_KEY, {"test": "test"}) | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 355 | hatchet.event.push( | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 400 | hatchet.event.push("key1", {"order": "first"}, scope=scope) | CODE |
| HIGH | sdks/python/examples/durable/test_durable.py | 419 | 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/test_conditions.py | 17 | hatchet.event.push("skip_on_event:skip", {}) | CODE |
| HIGH | sdks/python/examples/conditions/test_conditions.py | 18 | hatchet.event.push("wait_for_event:start", {}) | 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 | 189 | 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/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 | 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 | 48 | // ── Queries ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/organization-wrapper.ts | 131 | // ── Mutations ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/app/src/lib/api/organization-wrapper.ts | 316 | // ── User Groups ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/diagram-colors.ts | 8 | // ── Brand palette ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/diagram-colors.ts | 21 | // ── State colors (dashboard-consistent) ──────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/diagram-colors.ts | 35 | // ── Fills (used for node backgrounds at reduced opacity) ─────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/diagram-colors.ts | 50 | // ── Container styling ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/diagram-colors.ts | 56 | // ── Inactive / dimmed elements ───────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/docs/components/diagram-colors.ts | 68 | // ── Gradient stop pairs [start, end] for SVG linearGradient ──────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/webpack.config.js | 8 | // ─── Target 1: Extension host (Node.js) ─────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/webpack.config.js | 54 | // ─── Target 2: Webview React app (browser) ──────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/examples/custom-wrapper.ts | 21 | // ── Supporting types ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/examples/custom-wrapper.ts | 84 | // ── Factory function ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ontend/vscode-extension/examples/custom-task-method.ts | 66 | // ── Usage ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/panel/dag-panel.ts | 82 | // ─── Public API ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/panel/dag-panel.ts | 146 | // ─── Private ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/panel/dag-panel.ts | 278 | // ─── Helpers ───────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/go-parser.ts | 65 | // ── Pass 1: workflow declarations ──────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/go-parser.ts | 77 | // ── Pass 2: task declarations ───────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/go-parser.ts | 112 | // ── Build output ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/python-parser.ts | 39 | // ── Pass 1: workflow declarations ──────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/python-parser.ts | 51 | // ── Pass 2: task decorators ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/python-parser.ts | 96 | // ── Build output ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/ruby-parser.ts | 46 | // ── Pass 1: workflow declarations ──────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/ruby-parser.ts | 58 | // ── Pass 2: task declarations ───────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/ruby-parser.ts | 104 | // ── Build output ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/workflow-parser.ts | 171 | // ── Pass A: classify variable declarations ────────────────────────────── | COMMENT |
| MEDIUM | frontend/vscode-extension/src/parser/workflow-parser.ts | 226 | // ── Pass B: collect task calls grouped by receiver variable ───────────── | COMMENT |
| MEDIUM | sdks/ruby/generate.sh | 23 | # ── Protobuf / gRPC generation ────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/generate.sh | 58 | # ── REST API client generation ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/generate.sh | 97 | # ── Post-generation patches ────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/generate.sh | 143 | # ── Main ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/src/.rubocop.yml | 17 | # ─── Style ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/src/.rubocop.yml | 44 | # ─── Metrics ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/src/.rubocop.yml | 90 | # ─── Layout ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/src/.rubocop.yml | 108 | # ─── Naming ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/src/.rubocop.yml | 134 | # ─── Gemspec ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/src/.rubocop.yml | 139 | # ─── Lint ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | sdks/ruby/src/.rubocop.yml | 150 | # ─── Custom ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | api/v1/server/authn/session_helpers_test.go | 51 | // ── Step 1: prime the session ────────────────────────────────────────── | COMMENT |
| MEDIUM | api/v1/server/authn/session_helpers_test.go | 75 | // ── Step 2: attacker fires the exploit ──────────────────────────────── | COMMENT |
| MEDIUM | api/v1/server/authn/session_helpers_test.go | 86 | // ── Step 3: assert the expected (fixed) behaviour ───────────────────── | COMMENT |
| 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/hatchet_sdk/hatchet.py | 264 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 284 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 303 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 372 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 403 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 433 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 567 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 599 | CODE | |
| LOW | sdks/python/hatchet_sdk/hatchet.py | 634 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/events.py | 422 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/events.py | 449 | 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 | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/worker_api.py | 308 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/worker_api.py | 397 | CODE | |
| LOW | sdks/python/hatchet_sdk/clients/rest/api/worker_api.py | 486 | CODE | |
| LOW | …thon/hatchet_sdk/clients/rest/api/workflow_runs_api.py | 948 | CODE | |
| LOW | …thon/hatchet_sdk/clients/rest/api/workflow_runs_api.py | 1062 | CODE | |
| 69 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 | 164 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/clients/events.py | 399 | except Exception: | CODE |
| LOW | …ks/python/hatchet_sdk/clients/dispatcher/dispatcher.py | 148 | except Exception: | CODE |
| LOW | …thon/hatchet_sdk/clients/dispatcher/action_listener.py | 152 | except Exception: | CODE |
| LOW | …thon/hatchet_sdk/clients/dispatcher/action_listener.py | 310 | 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 | 373 | except Exception: | CODE |
| LOW⚡ | …atchet_sdk/clients/listeners/durable_event_listener.py | 379 | except Exception as e: | CODE |
| LOW⚡ | …atchet_sdk/clients/listeners/durable_event_listener.py | 386 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/clients/rest/exceptions.py | 132 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 478 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 537 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 555 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/context/context.py | 575 | 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 | 86 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/runnables/workflow.py | 246 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/runnables/workflow.py | 1142 | except Exception as e: | CODE |
| MEDIUM | sdks/python/hatchet_sdk/worker/worker.py | 383 | def _setup_loop(self) -> None: | CODE |
| MEDIUM | sdks/python/hatchet_sdk/worker/worker.py | 588 | def _cleanup_lifespan(self) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 337 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 348 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 585 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 594 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 625 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 654 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 702 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 721 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 748 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 278 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 305 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 424 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 479 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 482 | except Exception: | CODE |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 578 | except Exception: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 271 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 472 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 605 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 643 | except Exception as e: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 689 | except Exception as e: | CODE |
| LOW | …python/hatchet_sdk/worker/runner/utils/capture_logs.py | 146 | except Exception: | CODE |
| LOW | …/python/hatchet_sdk/worker/durable_eviction/manager.py | 124 | except Exception: | CODE |
| LOW | …/python/hatchet_sdk/worker/durable_eviction/manager.py | 204 | except Exception: | CODE |
| 30 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 | 3274 | // 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 | 104 | # Check if a parent task was skipped | COMMENT |
| LOW | sdks/ruby/src/lib/hatchet/context.rb | 144 | # 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 | 578 | # 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/sync-quickstart.sh | 63 | # Check if running in GitHub Actions | COMMENT |
| LOW | hack/sync-quickstart.sh | 103 | # Check if there are changes to commit | 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 | 196 | 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/docs/generator/llm.py | 8 | openai_api_key: str = "fake-key" | CODE |
| LOW | sdks/python/docs/generator/utils.py | 14 | openai_api_key: str = "fake-key" | 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 | 62 | 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 | frontend/snippets/generate.py | 325 | CODE | |
| LOW | …thon/hatchet_sdk/clients/dispatcher/action_listener.py | 71 | CODE | |
| LOW | …thon/hatchet_sdk/clients/dispatcher/action_listener.py | 143 | 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 | 338 | CODE | |
| LOW | …atchet_sdk/clients/listeners/durable_event_listener.py | 389 | 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 | 305 | CODE | |
| LOW | sdks/python/hatchet_sdk/runnables/task.py | 350 | CODE | |
| LOW | sdks/python/hatchet_sdk/runnables/task.py | 403 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 629 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 705 | CODE | |
| LOW | …s/python/hatchet_sdk/worker/action_listener_process.py | 380 | CODE | |
| LOW | sdks/python/hatchet_sdk/worker/runner/runner.py | 453 | CODE | |
| LOW | …python/hatchet_sdk/worker/runner/utils/capture_logs.py | 88 | 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 | 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/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 | 55 | def update_meta_js(documents: list[Document]) -> None: | STRING |
| LOW | sdks/python/hatchet_sdk/labels.py | 3 | __all__ = ["DesiredWorkerLabel", "WorkerLabel"] | CODE |
| LOW | sdks/python/hatchet_sdk/__init__.py | 192 | __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 | 415 | 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 | 383 | def _setup_loop(self) -> None: | CODE |
| LOW | sdks/python/hatchet_sdk/worker/worker.py | 657 | 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 |
|---|---|---|---|---|
| CRITICAL | sdks/python/hatchet_sdk/runnables/workflow.py | 2303 | wrr = self._workflow.client._client.runs.get_run_ref(run_id) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | sdks/go/client.go | 787 | // Example usage: | COMMENT |
| LOW | sdks/go/client.go | 826 | // 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 |
|---|---|---|---|---|
| HIGH | internal/msgqueue/postgres/msgqueue.go | 354 | // suffix appended to the queue name. In this implementation, there is no concept of an exchange. | 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 |
|---|---|---|---|---|
| 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 |
|---|---|---|---|---|
| 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 |