Repository Analysis

hatchet-dev/hatchet

🪓 An orchestration engine for background tasks, AI agents, and durable workflows

11.5 Low AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of hatchet-dev/hatchet, a Go project with 7,807 GitHub stars. SynthScan v2.0 examined 779,976 lines of code across 3990 source files, recording 4663 pattern matches distributed across 23 syntactic categories. The overall adjusted score of 11.5 places this repository in the Low AI signal band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

11.5
Adjusted Score
11.5
Raw Score
100%
Time Factor
2026-08-28
Last Push
7.8K
Stars
Go
Language
780.0K
Lines of Code
4.0K
Files
4.7K
Pattern Hits
2026-08-29
Scan Date
0.25
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

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.

Severity Breakdown

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.

CRITICAL 1HIGH 984MEDIUM 233LOW 3445

Directory Score Breakdown

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.

Pattern Findings

The scanner identified 4663 distinct pattern matches across 23 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Cross-File Repetition930 hits · 4650 pts
SeverityFileLineSnippetContext
HIGHsdks/python/hatchet_sdk/clients/rest/configuration.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGHsdks/python/hatchet_sdk/clients/rest/rest.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGHsdks/python/hatchet_sdk/clients/rest/__init__.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGHsdks/python/hatchet_sdk/clients/rest/exceptions.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGHsdks/python/hatchet_sdk/clients/rest/api_client.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…ks/python/hatchet_sdk/clients/rest/models/v1_filter.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…/hatchet_sdk/clients/rest/models/v1_task_event_list.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…et_sdk/clients/rest/models/list_api_tokens_response.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…het_sdk/clients/rest/models/workflow_update_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…ks/python/hatchet_sdk/clients/rest/models/otel_span.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…thon/hatchet_sdk/clients/rest/models/step_run_event.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…tchet_sdk/clients/rest/models/tenant_resource_limit.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…tchet_sdk/clients/rest/models/update_worker_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGHsdks/python/hatchet_sdk/clients/rest/models/worker.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…/hatchet_sdk/clients/rest/models/pull_request_state.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…ython/hatchet_sdk/clients/rest/models/queue_metrics.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…dk/clients/rest/models/info_get_version200_response.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…tchet_sdk/clients/rest/models/accept_invite_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…et_sdk/clients/rest/models/v1_create_filter_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…ython/hatchet_sdk/clients/rest/models/api_meta_auth.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…atchet_sdk/clients/rest/models/replay_event_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…chet_sdk/clients/rest/models/pause_workflow_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGHsdks/python/hatchet_sdk/clients/rest/models/user.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…dk/clients/rest/models/update_tenant_invite_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…s/python/hatchet_sdk/clients/rest/models/event_list.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…python/hatchet_sdk/clients/rest/models/v1_wait_item.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…tchet_sdk/clients/rest/models/v1_task_point_metrics.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…atchet_sdk/clients/rest/models/v1_cel_debug_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…t_sdk/clients/rest/models/rate_limit_order_by_field.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…on/hatchet_sdk/clients/rest/models/recent_step_runs.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…python/hatchet_sdk/clients/rest/models/pull_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…/hatchet_sdk/clients/rest/models/v1_cancelled_tasks.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…ython/hatchet_sdk/clients/rest/models/step_run_diff.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGHsdks/python/hatchet_sdk/clients/rest/models/event.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…et_sdk/clients/rest/models/create_api_token_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…tchet_sdk/clients/rest/models/step_run_archive_list.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…tchet_sdk/clients/rest/models/v1_logs_point_metrics.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…clients/rest/models/v1_branch_durable_task_response.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…t_sdk/clients/rest/models/create_api_token_response.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…k/clients/rest/models/webhook_worker_request_method.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…/hatchet_sdk/clients/rest/models/v1_task_run_status.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…thon/hatchet_sdk/clients/rest/models/log_line_level.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…/hatchet_sdk/clients/rest/models/tenant_member_list.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…/clients/rest/models/pause_workflow_request_unpause.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…on/hatchet_sdk/clients/rest/models/v1_workflow_type.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…hatchet_sdk/clients/rest/models/pagination_response.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…het_sdk/clients/rest/models/v1_webhook_api_key_auth.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…hon/hatchet_sdk/clients/rest/models/step_run_status.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGHsdks/python/hatchet_sdk/clients/rest/models/tenant.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…et_sdk/clients/rest/models/event_order_by_direction.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…atchet_sdk/clients/rest/models/v1_task_summary_list.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…chet_sdk/clients/rest/models/workflow_workers_count.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…on/hatchet_sdk/clients/rest/models/step_run_archive.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…/hatchet_sdk/clients/rest/models/workflow_run_shape.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…hatchet_sdk/clients/rest/models/concurrency_setting.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…ts/rest/models/v1_create_webhook_request_basic_auth.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…python/hatchet_sdk/clients/rest/models/worker_label.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…hatchet_sdk/clients/rest/models/scheduled_workflows.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…hon/hatchet_sdk/clients/rest/models/feature_flag_id.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
HIGH…dk/clients/rest/models/create_tenant_invite_request.py0hatchet api the hatchet api the version of the openapi document: 1.0.0 generated by openapi generator (https://openapi-gSTRING
870 more matches not shown…
Hyper-Verbose Identifiers1146 hits · 1106 pts
SeverityFileLineSnippetContext
LOWfrontend/app/src/query-client.tsx21function setupExchangeTokenRefreshTriggers() {CODE
LOWfrontend/app/src/router.tsx410async function getOrganizationIdForTenantInRouter(tenantId: string) {CODE
LOWfrontend/app/src/components/v1/ui/chart.tsx317function getPayloadConfigFromPayload(CODE
LOW…mponents/v1/molecules/time-picker/time-picker-utils.ts99function getValidArrowMinuteOrSecond(value: string, step: number) {CODE
LOW…t-prism/convert-otel-spans-to-agent-prism-span-tree.ts250function nestChildWorkflowRunsUnderProducers(nodes: OtelSpanTree[]): void {CODE
LOW…t-prism/convert-otel-spans-to-agent-prism-span-tree.ts287function suppressStandaloneQueuedSpans(nodes: OtelSpanTree[]): void {CODE
LOW…t-prism/convert-otel-spans-to-agent-prism-span-tree.ts295function synthesizeInProgressSpans(CODE
LOW…t-prism/convert-otel-spans-to-agent-prism-span-tree.ts407function suppressOrphanedChildWorkflows(CODE
LOW…t-prism/convert-otel-spans-to-agent-prism-span-tree.ts479function synthesizePendingTaskSpans(CODE
LOW…t-prism/convert-otel-spans-to-agent-prism-span-tree.ts570function attachWorkflowQueuedPhase(CODE
LOW…t-prism/convert-otel-spans-to-agent-prism-span-tree.ts742function computeDurationFromChildren(node: OtelSpanTree): void {CODE
LOW…t-prism/convert-otel-spans-to-agent-prism-span-tree.ts792function buildTreeFromTaskSummaries(CODE
LOW…d/app/src/components/v1/cloud/billing/subscription.tsx89function getPlanChangeErrorMessage(error: unknown) {CODE
LOW…/components/v1/cloud/billing/subscription-plan-code.ts3export function resolveSubscriptionPlanCode(CODE
LOW…nents/forms/organization-onboarding-questions-form.tsx48export function OrganizationOnboardingQuestionsForm({CODE
LOW…app/src/components/sso/SsoDeleteConfirmationDialog.tsx13export function SsoDeleteConfirmationDialog() {CODE
LOWfrontend/app/src/lib/breadcrumbs.ts155function generateOrganizationBreadcrumbs(CODE
LOWfrontend/app/src/lib/redirect-frontend-host.ts3export function domainRedirectSkipStorageKey(targetOrigin: string): string {CODE
LOWfrontend/app/src/lib/redirect-frontend-host.ts7export function parseRedirectFrontendOrigin(raw: string): URL | null {CODE
LOWfrontend/app/src/lib/redirect-frontend-host.ts22export function buildRedirectFrontendHref(CODE
LOWfrontend/app/src/lib/api/exchange-token.ts62export function exchangeTokenQueryOptions(CODE
LOWfrontend/app/src/lib/api/api.ts127export function resolveExchangeTokenTenantId(CODE
LOWfrontend/app/src/lib/api/api.ts198async function resolveControlPlaneEnabled(): Promise<boolean> {CODE
LOW…/app/src/pages/organizations/$organization/billing.tsx129function OrganizationBillingContent() {CODE
LOW…c/pages/main/v1/tenant-settings/organization/index.tsx244export function CloudOrganizationSettings({CODE
LOW…ng/components/update-tenant-alerting-settings-form.tsx34export function UpdateTenantAlertingSettings({CODE
LOW…ntegrations/components/prometheus-metrics-settings.tsx33export function PrometheusMetricsSettings() {CODE
LOW…ntegrations/components/prometheus-metrics-settings.tsx178function MetricsSelfHostInstructions({ tenantId }: { tenantId: string }) {CODE
LOW…rce-limits/components/tenant-resource-limits-table.tsx21export function TenantResourceLimitsTable({CODE
LOW…led-runs/components/expanded-scheduled-run-content.tsx10export function ExpandedScheduledRunContent({CODE
LOW…led-runs/components/bulk-reschedule-scheduled-runs.tsx13export function BulkRescheduleScheduledRuns({CODE
LOW…rkflow-runs-v1/components/runs-timeout-empty-state.tsx8export function RequestTimeoutCloudCTAEmptyState({CODE
LOW…in/v1/workflow-runs-v1/hooks/use-run-detail-search.tsx175export function RunDetailSearchLocalProvider({CODE
LOW…$run/v2components/step-run-events-for-workflow-run.tsx252function describeConditionCompletion(c: {CODE
LOW…/main/v1/workflow-runs-v1/$run/v2components/header.tsx165function TriggeringParentWorkflowRunSection({CODE
LOW…/$run/v2components/step-run-detail/step-run-detail.tsx416function TriggeringParentWorkflowRunSection({CODE
LOW…d-worker/components/managed-worker-instances-table.tsx17export function ManagedWorkerInstancesTable({CODE
LOWfrontend/docs/scripts/generate-llms.ts528function resolveMdxComponentImports(CODE
LOWfrontend/docs/lib/docs-languages.ts41export function getFixedPackageManagerMessage(CODE
LOW…nd/vscode-extension/src/providers/codelens-provider.ts21export function detectWorkflowDeclarations(CODE
LOW…nd/vscode-extension/src/providers/codelens-provider.ts65function parseWorkflowsForDocument(CODE
LOW…ntend/vscode-extension/src/parser/jsdoc-annotations.ts36export function scanFileForWorkflowAnnotations(CODE
LOW…ntend/vscode-extension/src/parser/jsdoc-annotations.ts103function tryExtractFromVariableStatement(CODE
LOWfrontend/vscode-extension/src/parser/go-parser.ts125export function detectGoWorkflowDeclarations(source: string): WorkflowDeclaration[] {CODE
LOWfrontend/vscode-extension/src/parser/python-parser.ts109export function detectPyWorkflowDeclarations(source: string): WorkflowDeclaration[] {CODE
LOWfrontend/vscode-extension/src/parser/ruby-parser.ts117export function detectRubyWorkflowDeclarations(source: string): WorkflowDeclaration[] {CODE
LOWfrontend/vscode-extension/src/parser/workflow-parser.ts124function extractWorkflowNameFromArgs(call: ts.CallExpression): string | undefined {CODE
LOWfrontend/vscode-extension/src/parser/workflow-parser.ts430export function detectTsWorkflowDeclarations(CODE
LOWsdks/python/conftest.py26async def supports_durable_eviction(engine_version: str | None) -> bool:CODE
LOWsdks/python/conftest.py33def _skip_unless_durable_eviction(supports_durable_eviction: bool) -> None:CODE
LOWsdks/python/conftest.py48def _skip_unless_observability(supports_observability: bool) -> None:CODE
LOWsdks/python/conftest.py78def _on_demand_worker_fixture(CODE
LOWsdks/python/apply_patches.py54def patch_contract_import_paths(content: str) -> str:CODE
LOWsdks/python/apply_patches.py62def patch_grpc_dispatcher_import(content: str) -> str:CODE
LOWsdks/python/apply_patches.py78def patch_grpc_workflows_import(content: str) -> str:CODE
LOWsdks/python/apply_patches.py86def patch_grpc_init_signature(content: str) -> str:CODE
LOWsdks/python/apply_patches.py138def patch_rest_transport_exceptions(content: str) -> str:CODE
LOWsdks/python/apply_patches.py332def patch_rest_error_diagnostics(content: str) -> str:STRING
LOWsdks/python/apply_patches.py560def apply_patches_to_matching_files(STRING
LOWsdks/python/apply_patches.py567def patch_api_client_datetime_format_on_post(content: str) -> str:STRING
1086 more matches not shown…
Unused Imports1338 hits · 1024 pts
SeverityFileLineSnippetContext
LOWsdks/python/tests/test_durable_eviction_cache.py1CODE
LOWsdks/python/tests/test_datetime_partitioning.py1CODE
LOWsdks/python/tests/test_cel_debugging.py6CODE
LOW…/concurrency_strategies/test_concurrency_strategies.py9CODE
LOWsdks/python/tests/unit/test_durable_event_listener.py1CODE
LOWsdks/python/tests/unit/test_durable_event_listener.py12CODE
LOWsdks/python/tests/unit/test_invocation_scoped_cache.py1CODE
LOWsdks/python/tests/unit/conftest.py4CODE
LOWsdks/python/tests/unit/test_aio_put_stream.py1CODE
LOWsdks/python/tests/unit/test_capture_logs.py1CODE
LOWsdks/python/tests/unit/test_capture_logs.py5CODE
LOWsdks/python/tests/unit/test_shutdown_ordering.py3CODE
LOW…ks/python/tests/unit/test_batch_run_instrumentation.py8CODE
LOWsdks/python/tests/unit/test_durable_eviction_manager.py1CODE
LOW…failure_on_timeout_with_multi_concurrency/test_case.py8CODE
LOWsdks/python/tests/child_spawn_cache_on_retry/worker.py4CODE
LOW…pawn_cache_on_retry/test_child_spawn_cache_on_retry.py7CODE
LOWsdks/python/hatchet_sdk/labels.py1CODE
LOWsdks/python/hatchet_sdk/labels.py1CODE
LOWsdks/python/hatchet_sdk/workflow_run.py13CODE
LOWsdks/python/hatchet_sdk/__init__.py14CODE
LOWsdks/python/hatchet_sdk/__init__.py17CODE
LOWsdks/python/hatchet_sdk/__init__.py17CODE
LOWsdks/python/hatchet_sdk/__init__.py17CODE
LOWsdks/python/hatchet_sdk/__init__.py24CODE
LOWsdks/python/hatchet_sdk/__init__.py25CODE
LOWsdks/python/hatchet_sdk/__init__.py26CODE
LOWsdks/python/hatchet_sdk/__init__.py27CODE
LOWsdks/python/hatchet_sdk/__init__.py28CODE
LOWsdks/python/hatchet_sdk/__init__.py29CODE
LOWsdks/python/hatchet_sdk/__init__.py30CODE
LOWsdks/python/hatchet_sdk/__init__.py31CODE
LOWsdks/python/hatchet_sdk/__init__.py32CODE
LOWsdks/python/hatchet_sdk/__init__.py35CODE
LOWsdks/python/hatchet_sdk/__init__.py38CODE
LOWsdks/python/hatchet_sdk/__init__.py41CODE
LOWsdks/python/hatchet_sdk/__init__.py44CODE
LOWsdks/python/hatchet_sdk/__init__.py45CODE
LOWsdks/python/hatchet_sdk/__init__.py46CODE
LOWsdks/python/hatchet_sdk/__init__.py47CODE
LOWsdks/python/hatchet_sdk/__init__.py48CODE
LOWsdks/python/hatchet_sdk/__init__.py49CODE
LOWsdks/python/hatchet_sdk/__init__.py52CODE
LOWsdks/python/hatchet_sdk/__init__.py53CODE
LOWsdks/python/hatchet_sdk/__init__.py56CODE
LOWsdks/python/hatchet_sdk/__init__.py59CODE
LOWsdks/python/hatchet_sdk/__init__.py60CODE
LOWsdks/python/hatchet_sdk/__init__.py61CODE
LOWsdks/python/hatchet_sdk/__init__.py62CODE
LOWsdks/python/hatchet_sdk/__init__.py65CODE
LOWsdks/python/hatchet_sdk/__init__.py68CODE
LOWsdks/python/hatchet_sdk/__init__.py69CODE
LOWsdks/python/hatchet_sdk/__init__.py70CODE
LOWsdks/python/hatchet_sdk/__init__.py71CODE
LOWsdks/python/hatchet_sdk/__init__.py74CODE
LOWsdks/python/hatchet_sdk/__init__.py75CODE
LOWsdks/python/hatchet_sdk/__init__.py76CODE
LOWsdks/python/hatchet_sdk/__init__.py77CODE
LOWsdks/python/hatchet_sdk/__init__.py78CODE
LOWsdks/python/hatchet_sdk/__init__.py79CODE
1278 more matches not shown…
Decorative Section Separators139 hits · 417 pts
SeverityFileLineSnippetContext
MEDIUMfrontend/app/src/lib/api/user-wrapper.ts14 // ── Queries ────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/app/src/lib/api/user-wrapper.ts66 // ── Mutations ──────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/app/src/lib/api/tenant-wrapper.ts16 // ── Queries ────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/app/src/lib/api/tenant-wrapper.ts58 // ── Mutations ──────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/app/src/lib/api/organization-wrapper.ts61 // ── Queries ────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/app/src/lib/api/organization-wrapper.ts144 // ── Mutations ──────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/app/src/lib/api/organization-wrapper.ts391 // ── User Groups ─────────────────────────────────────────────────────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/EmbeddedMode.tsx65// ─── Timing (ms) ───────────────────────────────────────────────────────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/EmbeddedMode.tsx86// ─── Component boxes (persistent tokens: separate → merged → reset) ────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/EmbeddedMode.tsx108// ─── Phase scenery (links, labels, boundary — fading tokens) ───────────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/EmbeddedMode.tsx156// ─── Chatter (dispatch → result → persist, in both phases) ─────────────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/EmbeddedMode.tsx222// ─── Export ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…/docs/components/flow-animations/QueueBackpressure.tsx70// ─── Timing (ms) ───────────────────────────────────────────────────────────COMMENT
MEDIUM…/docs/components/flow-animations/QueueBackpressure.tsx96// ─── Schedule (FIFO simulation, run once at module scope) ──────────────────COMMENT
MEDIUM…/docs/components/flow-animations/QueueBackpressure.tsx165// ─── Task tracks ───────────────────────────────────────────────────────────COMMENT
MEDIUM…/docs/components/flow-animations/QueueBackpressure.tsx228// ─── Live readouts (per-frame, no React renders) ───────────────────────────COMMENT
MEDIUM…/docs/components/flow-animations/QueueBackpressure.tsx336// ─── Static chrome ─────────────────────────────────────────────────────────COMMENT
MEDIUM…/docs/components/flow-animations/QueueBackpressure.tsx464// ─── Export ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/EventFanout.tsx50// ─── The event and the tasks subscribed to it ──────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/EventFanout.tsx67// ─── Timing constants (ms) ─────────────────────────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/EventFanout.tsx79// ─── Seeded schedule: four pushes of the same event ────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/EventFanout.tsx117// ─── Loop bookkeeping ──────────────────────────────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/EventFanout.tsx126// ─── Tracks ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/EventFanout.tsx197// ─── Static chrome ─────────────────────────────────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/EventFanout.tsx326// ─── Export ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx76// ─── Buckets ───────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx85// ─── Timing (ms) ───────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx110// ─── Schedule (round-robin simulation, run once at module scope) ───────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx248// ─── Object tracks (bucket → queue → worker slot → tally) ──────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx334// ─── list_objects trigger tracks (cron port → bucket, one per lane) ────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx378// ─── Cron pulse rings ──────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx395// ─── Round-robin cursor (glides to the queue head being pulled) ────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx442// ─── Live readouts (per-frame, no React renders) ───────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx576// ─── Static chrome ─────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/S3Pipeline.tsx750// ─── Export ────────────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/SlotCost.tsx60// ─── Timing (ms) ───────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/SlotCost.tsx87// ─── Loop wrapping ─────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/SlotCost.tsx146// ─── Light tasks (cost 1): per-cell occupancy schedules ────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/SlotCost.tsx324// ─── Heavy tasks (cost 5): one bar per column reservation ──────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/SlotCost.tsx405// ─── Static chrome ─────────────────────────────────────────────────────────COMMENT
MEDIUMfrontend/docs/components/flow-animations/SlotCost.tsx509// ─── Export ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…d/docs/components/flow-animations/DurableExecution.tsx62// ─── Timing (ms) — one scripted crash-and-replay loop ──────────────────────COMMENT
MEDIUM…d/docs/components/flow-animations/DurableExecution.tsx90// ─── Task tracks ───────────────────────────────────────────────────────────COMMENT
MEDIUM…d/docs/components/flow-animations/DurableExecution.tsx139// ─── Checkpoint chips + log records ────────────────────────────────────────COMMENT
MEDIUM…d/docs/components/flow-animations/DurableExecution.tsx217// ─── State machines: step cells + worker frames ────────────────────────────COMMENT
MEDIUM…d/docs/components/flow-animations/DurableExecution.tsx305// ─── Beat annotations (subtitle strip) ─────────────────────────────────────COMMENT
MEDIUM…d/docs/components/flow-animations/DurableExecution.tsx319// ─── Static chrome ─────────────────────────────────────────────────────────COMMENT
MEDIUM…d/docs/components/flow-animations/DurableExecution.tsx448// ─── Export ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/DurableWaits.tsx64// ─── Timing (ms) — one scripted sleep loop ─────────────────────────────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/DurableWaits.tsx92// ─── Track builders ────────────────────────────────────────────────────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/DurableWaits.tsx172// ─── Worker state: slot occupancy, load meter, idle dimming ────────────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/DurableWaits.tsx225// ─── Static chrome ─────────────────────────────────────────────────────────COMMENT
MEDIUM…ntend/docs/components/flow-animations/DurableWaits.tsx352// ─── Export ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/HumanInLoop.tsx62// ─── Timing (ms) — one scripted approval loop ──────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/HumanInLoop.tsx85// ─── Track builders ────────────────────────────────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/HumanInLoop.tsx173// ─── Worker state: slot occupancy, load meter, idle dimming ────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/HumanInLoop.tsx226// ─── Static chrome ─────────────────────────────────────────────────────────COMMENT
MEDIUM…ontend/docs/components/flow-animations/HumanInLoop.tsx369// ─── Export ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…docs/components/flow-animations/HeadOfLineBlocking.tsx66// ─── Timing (ms) ───────────────────────────────────────────────────────────COMMENT
MEDIUM…docs/components/flow-animations/HeadOfLineBlocking.tsx99// ─── Flood schedule (seeded jitter — deterministic, never Math.random) ─────COMMENT
79 more matches not shown…
AI Slop Vocabulary204 hits · 309 pts
SeverityFileLineSnippetContext
MEDIUM…/pages/main/v1/managed-workers/demo-template/index.tsx202 // Check if deployment is complete - make success detection more robustCOMMENT
LOW…et/clients/rest/lib/hatchet-sdk-rest/api_model_base.rb71 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…est/lib/hatchet-sdk-rest/models/step_run_event_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…t/lib/hatchet-sdk-rest/models/v1_cel_debug_response.rb260 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…/lib/hatchet-sdk-rest/models/webhook_worker_created.rb299 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…est/lib/hatchet-sdk-rest/models/v1_webhook_response.rb220 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…tchet-sdk-rest/models/v1_event_workflow_run_summary.rb327 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…st/lib/hatchet-sdk-rest/models/v1_webhook_hmac_auth.rb322 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…het-sdk-rest/models/event_update_cancel200_response.rb203 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…nts/rest/lib/hatchet-sdk-rest/models/v1_task_timing.rb572 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…rest/lib/hatchet-sdk-rest/models/trigger_run_result.rb237 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…chet-sdk-rest/models/v1_create_webhook_request_base.rb325 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…est/lib/hatchet-sdk-rest/models/cron_workflows_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…/rest/lib/hatchet-sdk-rest/models/workflow_run_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…t/clients/rest/lib/hatchet-sdk-rest/models/step_run.rb537 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…s/rest/lib/hatchet-sdk-rest/models/concurrency_stat.rb221 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…lients/rest/lib/hatchet-sdk-rest/models/tenant_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…et-sdk-rest/models/workflow_version_task_rate_limit.rb252 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…nts/rest/lib/hatchet-sdk-rest/models/otel_span_list.rb223 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…rest/models/create_tenant_alert_email_group_request.rb221 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…b/hatchet-sdk-rest/models/v1_update_webhook_request.rb232 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…het-sdk-rest/models/v1_update_http_operator_request.rb233 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…atchet-sdk-rest/models/user_tenant_memberships_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…t/lib/hatchet-sdk-rest/models/update_tenant_request.rb294 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…/lib/hatchet-sdk-rest/models/tenant_resource_policy.rb221 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…lients/rest/lib/hatchet-sdk-rest/models/v1_log_line.rb373 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…est/lib/hatchet-sdk-rest/models/list_slack_webhooks.rb246 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…rest/lib/hatchet-sdk-rest/models/user_login_request.rb246 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…clients/rest/lib/hatchet-sdk-rest/models/event_data.rb219 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…t/lib/hatchet-sdk-rest/models/v1_http_operator_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…ents/rest/lib/hatchet-sdk-rest/models/slack_webhook.rb353 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…atchet-sdk-rest/models/user_change_password_request.rb246 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…ib/hatchet-sdk-rest/models/scheduled_workflows_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…chet-sdk-rest/models/v1_create_webhook_request_hmac.rb387 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…nts/rest/lib/hatchet-sdk-rest/models/webhook_worker.rb272 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…t/lib/hatchet-sdk-rest/models/v1_webhook_basic_auth.rb246 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…t/clients/rest/lib/hatchet-sdk-rest/models/workflow.rb369 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…/lib/hatchet-sdk-rest/models/webhook_worker_request.rb295 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…st/lib/hatchet-sdk-rest/models/v1_task_point_metric.rb270 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…b/hatchet-sdk-rest/models/bulk_create_event_request.rb220 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…t-sdk-rest/models/v1_create_webhook_request_api_key.rb387 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…ts/rest/lib/hatchet-sdk-rest/models/v1_task_summary.rb833 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…ls/workflow_run_shape_item_for_workflow_run_details.rb334 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…lients/rest/lib/hatchet-sdk-rest/models/worker_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…nts/rest/lib/hatchet-sdk-rest/models/v1_task_filter.rb260 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…het-sdk-rest/models/v1_create_http_operator_request.rb327 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…hatchet-sdk-rest/models/list_pull_requests_response.rb220 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…nts/rest/lib/hatchet-sdk-rest/models/cron_workflows.rb490 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…ts/rest/lib/hatchet-sdk-rest/models/rate_limit_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…/rest/lib/hatchet-sdk-rest/models/api_resource_meta.rb291 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…est/lib/hatchet-sdk-rest/models/worker_runtime_info.rb259 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…atchet-sdk-rest/models/workflow_runs_cancel_request.rb220 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…/lib/hatchet-sdk-rest/models/rerun_step_run_request.rb218 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…ents/rest/lib/hatchet-sdk-rest/models/workflow_list.rb221 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…ts/rest/lib/hatchet-sdk-rest/models/v1_webhook_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…rest/lib/hatchet-sdk-rest/models/tenant_invite_list.rb212 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…ib/hatchet-sdk-rest/models/tenant_alerting_settings.rb295 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…dk-rest/models/create_cron_workflow_trigger_request.rb333 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…ients/rest/lib/hatchet-sdk-rest/models/workflow_tag.rb246 # For object, use to_hash. Otherwise, just return the valueCOMMENT
LOW…chet-sdk-rest/models/v1_branch_durable_task_request.rb291 # For object, use to_hash. Otherwise, just return the valueCOMMENT
144 more matches not shown…
Over-Commented Block303 hits · 294 pts
SeverityFileLineSnippetContext
LOWcmd/hatchet-loadtest/timing.go21const timingPendingTTL = 5 * time.MinuteCOMMENT
LOWcmd/hatchet-loadtest/timing.go241 // being retried after a prior failure) - don't reconsider it.COMMENT
LOWcmd/hatchet-cli/cli/quickstart_e2e_test.go21 useCase stringCOMMENT
LOW…chet-cli/cli/internal/patternmatcher/patternmatcher.go81// and isn't excluded by any of the subsequent patterns.COMMENT
LOW…chet-cli/cli/internal/patternmatcher/patternmatcher.go161 }COMMENT
LOWfrontend/app/.eslintrc.json61 // "@typescript-eslint/no-explicit-any": "error",COMMENT
LOWfrontend/app/.eslintrc.json81 // "no-alert": "error",COMMENT
LOWfrontend/app/.eslintrc.json101 // // We should turn this on later to enforce using `useCallback` instead of inline functionsCOMMENT
LOW…ows/$workflow/components/workflow-general-settings.tsx121 )}COMMENT
LOWfrontend/app/src/pages/main/v1/overview/index.tsx221 const hasConnectedWorker = hasQualifiedWorker(COMMENT
LOW…naged-workers/create/components/create-worker-form.tsx421 ) {COMMENT
LOW…naged-workers/create/components/create-worker-form.tsx441 // href="/api/v1/cloud/users/github-app/start"COMMENT
LOWsdks/go/hatchet.go1// Define workflows that can declare tasks and be run, scheduled, and so on.COMMENT
LOWsdks/go/hatchet.go21//COMMENT
LOWsdks/go/hatchet.go41// - Nested workflow execution: https://github.com/hatchet-dev/hatchet/tree/main/sdks/go/examples/child-workflowsCOMMENT
LOWsdks/go/client.go701//COMMENT
LOWsdks/go/client.go741 task := workflow.NewBatchTask(name, fn, batch, taskOptions...)COMMENT
LOWsdks/go/client.go881COMMENT
LOWsdks/go/deprecation.go41COMMENT
LOWsdks/go/workflow.go601// NewBatchTask transforms a function into a Hatchet batch task that runs as part of aCOMMENT
LOWsdks/go/docs/generator/main.go1// Command generator emits the Go SDK reference docs (fumadocs .mdx pages) from theCOMMENT
LOWsdks/python/hatchet_sdk/deprecated/__init__.py1# Legacy worker registration code for backward compatibility with older Hatchet enginesCOMMENT
LOWsdks/python/examples/delayed/test_delayed.py1# from hatchet_sdk import HatchetCOMMENT
LOWsdks/typescript/tsconfig.json21 "lib": ["ES2022"],COMMENT
LOWsdks/typescript/tsconfig.json41 "@hatchet/*": ["./src/*"],COMMENT
LOWsdks/typescript/tsconfig.json61COMMENT
LOWsdks/typescript/tsconfig.json81 // "mapRoot": "", /* Specify the location where debugger should locate map files COMMENT
LOWsdks/typescript/tsconfig.json101 "strict": true /* Enable all strict type-checking options. */,COMMENT
LOWsdks/typescript/jest.config.ts21 // Indicates whether the coverage information should be collected while executing the testCOMMENT
LOWsdks/typescript/jest.config.ts41 // "text",COMMENT
LOWsdks/typescript/jest.config.ts61 // forceCoverageMatch: [],COMMENT
LOWsdks/typescript/jest.config.ts81 // moduleFileExtensions: [COMMENT
LOWsdks/typescript/jest.config.ts101 // An enum that specifies notification mode. Requires { notify: true }COMMENT
LOWsdks/typescript/jest.config.ts121COMMENT
LOWsdks/typescript/jest.config.ts141COMMENT
LOWsdks/typescript/jest.config.ts181 '^@hatchet/(.*)$': '<rootDir>/src/$1',COMMENT
LOWsdks/typescript/src/v1/declaration.ts821 // pause() {COMMENT
LOWsdks/typescript/src/v1/client/features/workflows.ts161 throw error;COMMENT
LOWsdks/typescript/src/v1/client/features/workflows.ts181 // const { data } = await this.api.workflowUpdate(workflowObj.metadata.id, {COMMENT
LOWsdks/typescript/src/v1/client/features/workflows.ts201 // async unpause(workflow: string | WorkflowDeclaration<any, any> | Workflow) {COMMENT
LOWsdks/typescript/src/v1/client/features/workflows.ts221 // });COMMENT
LOW…escript/src/clients/dispatcher/action-listener.test.ts81 // const listener = new ActionListener(COMMENT
LOW…escript/src/clients/dispatcher/action-listener.test.ts101 // taskId: 'step1',COMMENT
LOW…escript/src/clients/dispatcher/action-listener.test.ts121 // res.push(action);COMMENT
LOW…escript/src/clients/dispatcher/action-listener.test.ts141 // it('it should attempt to re-establish connection on grpc UNAVAILABLE', async () => {COMMENT
LOW…escript/src/clients/dispatcher/action-listener.test.ts161 // mockListener(mockAssignedActions),COMMENT
LOW…escript/src/clients/dispatcher/action-listener.test.ts181 // // throw new Error('Simulated error');COMMENT
LOW…escript/src/clients/dispatcher/action-listener.test.ts201 // await listener.getListenClient();COMMENT
LOW…escript/src/clients/dispatcher/action-listener.test.ts221 // })COMMENT
LOW…escript/src/clients/dispatcher/action-listener.test.ts241 describe('unregister', () => {COMMENT
LOW…cript/src/clients/dispatcher/dispatcher-client.test.ts61 // tenantId: 'TENANT_ID',COMMENT
LOWsdks/ruby/generate.sh1#!/bin/bashCOMMENT
LOWsdks/ruby/docs/generate.rb1# frozen_string_literal: trueCOMMENT
LOWsdks/ruby/src/lib/hatchet-sdk.rb81 # namespace: "production"COMMENT
LOWsdks/ruby/src/lib/hatchet-sdk.rb201 # scheduled, and so on.COMMENT
LOWsdks/ruby/src/lib/hatchet-sdk.rb221 # Create a standalone Hatchet task. The task is automatically wrapped in aCOMMENT
LOWsdks/ruby/src/lib/hatchet-sdk.rb241 wf.task(name, **opts, &block)COMMENT
LOWsdks/ruby/src/lib/hatchet-sdk.rb261 # batch = hatchet.batch_task(name: "my_batch", batch: Hatchet::BatchTaskConfig.new(max_size: 3)) do |inputs, ctx|COMMENT
LOWsdks/ruby/src/lib/hatchet-sdk.rb281 wf = Workflow.new(name: name, client: self,COMMENT
LOWsdks/ruby/src/lib/hatchet-sdk.rb341 # @return [Hatchet::Clients::Grpc::EventClient]COMMENT
243 more matches not shown…
Cross-Language Confusion51 hits · 282 pts
SeverityFileLineSnippetContext
HIGHsdks/python/tests/unit/test_durable_event_listener.py399 s2.push(CODE
HIGHsdks/python/examples/concurrency_limit_rr_load/event.py13 hatchet.event.push("concurrency-test", {"group": group})CODE
HIGH…amples/opentelemetry_instrumentation/hyperdx/worker.py77 hatchet.event.push(CODE
HIGHsdks/python/examples/durable/test_durable.py377 hatchet.event.push(EVENT_KEY, {"order": "first"}, scope=scope)CODE
HIGHsdks/python/examples/durable/test_durable.py389 hatchet.event.push(CODE
HIGHsdks/python/examples/durable/test_durable.py140 hatchet.event.push(EVENT_KEY, {"test": "test"})CODE
HIGHsdks/python/examples/durable/test_durable.py357 hatchet.event.push(CODE
HIGHsdks/python/examples/durable/test_durable.py402 hatchet.event.push("key1", {"order": "first"}, scope=scope)CODE
HIGHsdks/python/examples/durable/test_durable.py421 event = hatchet.event.push(CODE
HIGHsdks/python/examples/durable/trigger.py19hatchet.event.push(EVENT_KEY, AwaitedEvent(id="123").model_dump(mode="json"))CODE
HIGHsdks/python/examples/conditions/trigger.py9hatchet.event.push("skip_on_event:skip", {})CODE
HIGHsdks/python/examples/conditions/trigger.py10hatchet.event.push("wait_for_event:start", {})CODE
HIGHsdks/python/examples/welcome_email/trigger.py20hatchet.event.push(CODE
HIGHsdks/python/examples/durable_event/trigger.py17hatchet.event.push(CODE
HIGH…hon/examples/durable_eviction/test_durable_eviction.py190 hatchet.event.push(EVENT_KEY, {})CODE
HIGHsdks/python/examples/events/event.py7hatchet.event.push("user:create", {"should_skip": False})CODE
HIGHsdks/python/examples/events/event.py11hatchet.event.push(CODE
HIGHsdks/python/examples/events/test_event.py49 or f"input.should_skip == false && payload.test_run_id == '{test_run_id}'"CODE
HIGHsdks/python/examples/events/test_event.py236 e = hatchet.event.push(EVENT_KEY, cp(False))CODE
HIGHsdks/python/examples/events/test_event.py436 "input.should_skip == false && payload.foobar == 'baz'",CODE
HIGHsdks/python/examples/events/test_event.py460 "input.should_skip == false && payload.foobar == 'baz'",CODE
HIGHsdks/python/examples/events/filter.py23hatchet.event.push(CODE
HIGHsdks/python/examples/events/filter.py33hatchet.event.push(CODE
HIGHsdks/python/examples/support_agent/trigger.py22hatchet.event.push(CODE
HIGHhack/db/generate-oss-db-model.py476const state = {{ scale: 0.55, x: 20, y: 20, selected: null, visible: new Set() }};CODE
HIGHhack/db/generate-oss-db-model.py524 if (column.primaryKey && column.foreignKey) return 'PK/FK';CODE
HIGHhack/db/generate-oss-db-model.py596 edgeElements.push(path);CODE
HIGHhack/db/generate-oss-db-model.py640 if (column.primaryKey) labels.push('primary key');CODE
HIGHhack/db/generate-oss-db-model.py641 if (column.foreignKey) labels.push('foreign key');CODE
HIGHhack/db/generate-oss-db-model.py642 if (column.default !== null) labels.push(`default: ${{column.default}}`);CODE
HIGHhack/db/generate-oss-db-model.py642 if (column.default !== null) labels.push(`default: ${{column.default}}`);CODE
HIGHhack/db/generate-oss-db-model.py683 for (const edge of edgeElements) edge.classList.toggle('active', edge.dataset.source === name || edge.dataset.target =CODE
HIGHhack/db/generate-oss-db-model.py687 if (center && positions.has(name)) centerTable(name);CODE
HIGHhack/db/generate-oss-db-model.py696 const visible = (!source || table.source === source) && (!query || haystack.includes(query));CODE
HIGHhack/db/generate-oss-db-model.py704 const anyVisible = hatchetOssModel.tables.some(table => table.source === label.dataset.source && state.visible.has(tCODE
HIGHhack/db/generate-oss-db-model.py742let drag = null;CODE
HIGHhack/db/generate-oss-db-model.py755viewport.addEventListener('pointerup', () => {{ drag = null; viewport.classList.remove('dragging'); }});CODE
HIGHhack/db/generate-oss-db-model.py761viewport.addEventListener('click', () => selectTable(null, false));CODE
HIGHhack/dev/compression-test/tests/python_test.py39 hatchet.event.push("compression-test:event", event)CODE
HIGHexamples/python/concurrency_limit_rr_load/event.py13 hatchet.event.push("concurrency-test", {"group": group})CODE
HIGH…python/opentelemetry_instrumentation/hyperdx/worker.py77 hatchet.event.push(CODE
HIGHexamples/python/durable/trigger.py19hatchet.event.push(EVENT_KEY, AwaitedEvent(id="123").model_dump(mode="json"))CODE
HIGHexamples/python/conditions/trigger.py9hatchet.event.push("skip_on_event:skip", {})CODE
HIGHexamples/python/conditions/trigger.py10hatchet.event.push("wait_for_event:start", {})CODE
HIGHexamples/python/welcome_email/trigger.py20hatchet.event.push(CODE
HIGHexamples/python/durable_event/trigger.py17hatchet.event.push(CODE
HIGHexamples/python/events/event.py7hatchet.event.push("user:create", {"should_skip": False})CODE
HIGHexamples/python/events/event.py10hatchet.event.push(CODE
HIGHexamples/python/events/filter.py22hatchet.event.push(CODE
HIGHexamples/python/events/filter.py31hatchet.event.push(CODE
HIGHexamples/python/support_agent/trigger.py22hatchet.event.push(CODE
Self-Referential Comments74 hits · 242 pts
SeverityFileLineSnippetContext
MEDIUMTaskfile.yaml337 # Create a trap to kill the watcher when the task exitsCOMMENT
MEDIUMcmd/hatchet-cli/cli/profile.go38# Create a new profile (interactive)COMMENT
MEDIUMcmd/hatchet-cli/cli/profile.go41# Create a new profile (non-interactive)COMMENT
MEDIUMcmd/hatchet-cli/cli/profile.go78 Example: ` # Create a new profile interactively (prompts for token)CODE
MEDIUMcmd/hatchet-cli/cli/profile.go81 # Create a new profile with a specific nameCOMMENT
MEDIUMsdks/python/hatchet_sdk/logger.py4# Create a named loggerCOMMENT
MEDIUM…ks/python/hatchet_sdk/contracts/dispatcher_pb2_grpc.py316 # This class is part of an EXPERIMENTAL API.COMMENT
MEDIUMsdks/python/hatchet_sdk/contracts/events_pb2_grpc.py132 # This class is part of an EXPERIMENTAL API.COMMENT
MEDIUMsdks/python/hatchet_sdk/contracts/workflows_pb2_grpc.py135 # This class is part of an EXPERIMENTAL API.COMMENT
MEDIUM…python/hatchet_sdk/contracts/v1/dispatcher_pb2_grpc.py101 # This class is part of an EXPERIMENTAL API.COMMENT
MEDIUM…/python/hatchet_sdk/contracts/v1/workflows_pb2_grpc.py150 # This class is part of an EXPERIMENTAL API.COMMENT
MEDIUMsdks/python/examples/concurrency_limit_rr_load/event.py7# Create a list of events with desired distributionCOMMENT
MEDIUMsdks/ruby/src/spec/hatchet/features/runs_spec.rb40 # Create the client to trigger the API initializationCOMMENT
MEDIUM…s/ruby/src/spec/integration/events_integration_spec.rb331 # Create a unique event firstCOMMENT
MEDIUMsdks/ruby/src/spec/support/integration_helper.rb16 # Create a test client for integration testsCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet-sdk.rb200 # Define a Hatchet workflow, which can then declare tasks and be run,COMMENT
MEDIUMsdks/ruby/src/lib/hatchet-sdk.rb221 # Create a standalone Hatchet task. The task is automatically wrapped in aCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet-sdk.rb244 # Create a standalone batch task (auto-wraps in a single-task workflow).COMMENT
MEDIUMsdks/ruby/src/lib/hatchet-sdk.rb268 # Create a standalone _durable_ Hatchet task, which works using Hatchet'sCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet-sdk.rb287 # Create a Hatchet worker on which to run workflows.COMMENT
MEDIUMsdks/ruby/src/lib/hatchet/worker_obj.rb257 # Create the action listener with retry/reconnect logicCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/workflow.rb101 # Define a task within this workflow. The block receives the workflow inputCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/workflow.rb132 # Define a durable task within this workflow.COMMENT
MEDIUMsdks/ruby/src/lib/hatchet/workflow.rb146 # Define a batch task within this workflow.COMMENT
MEDIUMsdks/ruby/src/lib/hatchet/workflow.rb165 # Define an on_failure task for this workflowCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/workflow.rb180 # Define an on_success task for this workflowCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/workflow.rb306 # Create a bulk run item for this workflow, intended to be used with theCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/workflow.rb333 # Create a cron trigger for this workflow.COMMENT
MEDIUMsdks/ruby/src/lib/hatchet/durable_context.rb178 # Create a request enumerator for the bidi streamCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/clients.rb4# This module provides access to different client types (REST, gRPC, etc.)COMMENT
MEDIUMsdks/ruby/src/lib/hatchet/clients.rb19 # Create a REST API client using the provided Hatchet configurationCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/connection.rb20 # Create a new gRPC channel for the given configuration.COMMENT
MEDIUMsdks/ruby/src/lib/hatchet/conditions.rb103 # Create an OR condition groupCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/task.rb267 # Create a bulk run item for use with run_manyCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/clients/rest.rb26 # Create a Configuration instance from a Hatchet::ConfigCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/clients/rest/.rubocop.yml1# This file is based on https://github.com/rails/rails/blob/master/.rubocop.yml (MIT license)COMMENT
MEDIUMsdks/ruby/src/lib/hatchet/clients/rest/.rubocop.yml87# Defining a method with parameters needs parentheses.COMMENT
MEDIUM…et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb22 # Create a filterCOMMENT
MEDIUM…et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb23 # Create a new filterCOMMENT
MEDIUM…et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb33 # Create a filterCOMMENT
MEDIUM…et/clients/rest/lib/hatchet-sdk-rest/api/filter_api.rb34 # Create a new filterCOMMENT
MEDIUM…t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb22 # Create a webhookCOMMENT
MEDIUM…t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb23 # Create a new webhookCOMMENT
MEDIUM…t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb33 # Create a webhookCOMMENT
MEDIUM…t/clients/rest/lib/hatchet-sdk-rest/api/webhook_api.rb34 # Create a new webhookCOMMENT
MEDIUM…ents/rest/lib/hatchet-sdk-rest/api/workflow_run_api.rb23 # Create a new cron job workflow trigger for a tenantCOMMENT
MEDIUM…ents/rest/lib/hatchet-sdk-rest/api/workflow_run_api.rb35 # Create a new cron job workflow trigger for a tenantCOMMENT
MEDIUM…t/clients/rest/lib/hatchet-sdk-rest/api/default_api.rb331 # Create a webhookCOMMENT
MEDIUM…t/clients/rest/lib/hatchet-sdk-rest/api/default_api.rb342 # Create a webhookCOMMENT
MEDIUM…/clients/rest/lib/hatchet-sdk-rest/api/operator_api.rb22 # Create an HTTP operatorCOMMENT
MEDIUM…/clients/rest/lib/hatchet-sdk-rest/api/operator_api.rb23 # Create a new HTTP operatorCOMMENT
MEDIUM…/clients/rest/lib/hatchet-sdk-rest/api/operator_api.rb33 # Create an HTTP operatorCOMMENT
MEDIUM…/clients/rest/lib/hatchet-sdk-rest/api/operator_api.rb34 # Create a new HTTP operatorCOMMENT
MEDIUM…clients/rest/lib/hatchet-sdk-rest/api/api_token_api.rb23 # Create an API token for a tenantCOMMENT
MEDIUM…clients/rest/lib/hatchet-sdk-rest/api/api_token_api.rb34 # Create an API token for a tenantCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/features/filters.rb7 # This class provides a high-level interface for creating, retrieving,COMMENT
MEDIUMsdks/ruby/src/lib/hatchet/features/filters.rb67 # Create a new filterCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/features/rate_limits.rb7 # This class provides a high-level interface for creating and updatingCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/features/workers.rb7 # This class provides a high-level interface for retrieving, listing, andCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet/features/runs.rb70 # This class provides a high-level interface for creating and managing workflow runsCOMMENT
14 more matches not shown…
AI Structural Patterns140 hits · 122 pts
SeverityFileLineSnippetContext
LOWsdks/python/hatchet_sdk/hatchet.py313CODE
LOWsdks/python/hatchet_sdk/hatchet.py337CODE
LOWsdks/python/hatchet_sdk/hatchet.py360CODE
LOWsdks/python/hatchet_sdk/hatchet.py439CODE
LOWsdks/python/hatchet_sdk/hatchet.py475CODE
LOWsdks/python/hatchet_sdk/hatchet.py510CODE
LOWsdks/python/hatchet_sdk/hatchet.py658CODE
LOWsdks/python/hatchet_sdk/hatchet.py690CODE
LOWsdks/python/hatchet_sdk/hatchet.py722CODE
LOWsdks/python/hatchet_sdk/hatchet.py754CODE
LOWsdks/python/hatchet_sdk/hatchet.py788CODE
LOWsdks/python/hatchet_sdk/hatchet.py924CODE
LOWsdks/python/hatchet_sdk/hatchet.py960CODE
LOWsdks/python/hatchet_sdk/hatchet.py999CODE
LOWsdks/python/hatchet_sdk/clients/events.py438CODE
LOWsdks/python/hatchet_sdk/clients/events.py465CODE
LOWsdks/python/hatchet_sdk/clients/rest/configuration.py198CODE
LOWsdks/python/hatchet_sdk/clients/rest/api_client.py137CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/log_api.py48CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/log_api.py162CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/log_api.py276CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/log_api.py491CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/log_api.py616CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/log_api.py741CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/log_api.py970CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/log_api.py1113CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/log_api.py1256CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/event_api.py1740CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/event_api.py1877CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/event_api.py2014CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/event_api.py3407CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/event_api.py3553CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/event_api.py3699CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/webhook_api.py916CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/webhook_api.py1013CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/webhook_api.py1110CODE
LOW…python/hatchet_sdk/clients/rest/api/rate_limits_api.py328CODE
LOW…python/hatchet_sdk/clients/rest/api/rate_limits_api.py430CODE
LOW…python/hatchet_sdk/clients/rest/api/rate_limits_api.py532CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/task_api.py1578CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/task_api.py1692CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/task_api.py1806CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/filter_api.py944CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/filter_api.py1043CODE
LOWsdks/python/hatchet_sdk/clients/rest/api/filter_api.py1142CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py95CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py217CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py339CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py3226CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py3315CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py3404CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py3860CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py3980CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py4100CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py4627CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py4800CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py4973CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py6512CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py6644CODE
LOW…ks/python/hatchet_sdk/clients/rest/api/workflow_api.py6776CODE
80 more matches not shown…
Structural Annotation Overuse64 hits · 117 pts
SeverityFileLineSnippetContext
LOW…ill-assets/hatchet-cli/references/trigger-and-watch.md10## Step 1: Write Input to a Temp FileCOMMENT
LOW…ill-assets/hatchet-cli/references/trigger-and-watch.md23## Step 2: Trigger the WorkflowCOMMENT
LOW…ill-assets/hatchet-cli/references/trigger-and-watch.md31## Step 3: Poll for CompletionCOMMENT
LOW…ill-assets/hatchet-cli/references/trigger-and-watch.md45## Step 4: Handle FailureCOMMENT
LOW…ill-assets/hatchet-cli/references/trigger-and-watch.md65## Step 5: Clean UpCOMMENT
LOW…i/cli/skill-assets/hatchet-cli/references/setup-cli.md5## Step 1: Check if Already InstalledCOMMENT
LOW…i/cli/skill-assets/hatchet-cli/references/setup-cli.md15## Step 2: Install the CLICOMMENT
LOW…i/cli/skill-assets/hatchet-cli/references/setup-cli.md35## Step 3: Check for Existing ProfilesCOMMENT
LOW…i/cli/skill-assets/hatchet-cli/references/setup-cli.md45## Step 4: Create a ProfileCOMMENT
LOW…i/cli/skill-assets/hatchet-cli/references/setup-cli.md61## Step 5: Verify ConnectivityCOMMENT
LOW…i/cli/skill-assets/hatchet-cli/references/debug-run.md5## Step 1: Get Run StateCOMMENT
LOW…i/cli/skill-assets/hatchet-cli/references/debug-run.md19## Step 2: Get Event LogCOMMENT
LOW…i/cli/skill-assets/hatchet-cli/references/debug-run.md34## Step 3: Get LogsCOMMENT
LOW…/cli/skill-assets/hatchet-cli/references/replay-run.md5## Step 1: Inspect the Original RunCOMMENT
LOW…/cli/skill-assets/hatchet-cli/references/replay-run.md55## Step 3: Watch the New RunCOMMENT
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts9 // Step 1: Login as owner and create a tenantCOMMENT
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts64 // Step 2: Create an invite for the member userCOMMENT
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts84 // Step 4: Login as member (who has pending invite)COMMENT
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts108 // Step 5: Decline all invitesCOMMENT
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts141 // Step 6: Verify the modal closes after all invites are declinedCOMMENT
LOWsdks/go/examples/dag/main.go31 // Step 1: Initial processingCOMMENT
LOWsdks/go/examples/dag/main.go41 // Step 2: Depends on step 1COMMENT
LOWsdks/go/examples/dag/main.go57 // Step 3: Also depends on step 1, parallel to step 2COMMENT
LOWsdks/go/examples/opentelemetry_instrumentation/main.go208 // Step 3: Send order confirmation (runs after both payment and inventory are done).COMMENT
LOWsdks/go/examples/with-workflows/main.go30 // Step 1: Initial processingCOMMENT
LOWsdks/go/examples/with-workflows/main.go38 // Step 2: Depends on step 1COMMENT
LOWsdks/go/examples/with-workflows/main.go52 // Step 3: Also depends on step 1, parallel to step 2COMMENT
LOWsdks/python/examples/welcome_email/worker.py43 # Step 1: Send the welcome emailCOMMENT
LOWsdks/python/examples/welcome_email/worker.py46 # Step 2: Wait for the user to complete onboarding, or time outCOMMENT
LOWsdks/python/examples/support_agent/worker.py135 # Step 1: Triage the ticketCOMMENT
LOWsdks/python/examples/support_agent/worker.py138 # Step 2: Generate an initial replyCOMMENT
LOWsdks/python/examples/support_agent/worker.py141 # Step 3: Wait for a customer reply or timeoutCOMMENT
LOW…s/typescript/src/v1/examples/welcome_email/workflow.ts28 // Step 1: Send the welcome emailCOMMENT
LOW…s/typescript/src/v1/examples/welcome_email/workflow.ts31 // Step 2: Wait for the user to complete onboarding, or time outCOMMENT
LOW…s/typescript/src/v1/examples/support_agent/workflow.ts123 // Step 1: Triage the ticketCOMMENT
LOW…s/typescript/src/v1/examples/support_agent/workflow.ts126 // Step 2: Generate an initial replyCOMMENT
LOW…s/typescript/src/v1/examples/support_agent/workflow.ts129 // Step 3: Wait for a customer reply or timeoutCOMMENT
LOW.claude/skills/build-tui-view/SKILL.md463#### Step 1: Create View FileCOMMENT
LOW.claude/skills/build-tui-view/SKILL.md533#### Step 2: Use View in TUICOMMENT
LOW.claude/skills/build-tui-view/SKILL.md1354#### Step 1: Create Debug Logger (if not exists)COMMENT
LOW.claude/skills/build-tui-view/SKILL.md1455#### Step 2: Integrate Debug Logger in Your ViewCOMMENT
LOW.claude/skills/build-tui-view/SKILL.md1480#### Step 3: Add Debug Logging Throughout ViewCOMMENT
LOW.claude/skills/build-tui-view/SKILL.md1502#### Step 4: Add Toggle Key HandlerCOMMENT
LOW.claude/skills/build-tui-view/SKILL.md1527#### Step 5: Implement Debug View RenderingCOMMENT
LOW.claude/skills/build-tui-view/SKILL.md1608#### Step 6: Update Footer ControlsCOMMENT
LOWhack/dev/compression-test/README.md23### Step 1: Build Baseline Images (Main Branch)COMMENT
LOWhack/dev/compression-test/README.md47### Step 2: Build Compression Images (Current Branch)COMMENT
LOWexamples/go/dag/main.go30 // Step 1: Initial processingCOMMENT
LOWexamples/go/dag/main.go39 // Step 2: Depends on step 1COMMENT
LOWexamples/go/dag/main.go54 // Step 3: Also depends on step 1, parallel to step 2COMMENT
LOWexamples/go/opentelemetry_instrumentation/main.go208 // Step 3: Send order confirmation (runs after both payment and inventory are done).COMMENT
LOWexamples/go/with-workflows/main.go30 // Step 1: Initial processingCOMMENT
LOWexamples/go/with-workflows/main.go38 // Step 2: Depends on step 1COMMENT
LOWexamples/go/with-workflows/main.go52 // Step 3: Also depends on step 1, parallel to step 2COMMENT
LOWexamples/python/welcome_email/worker.py42 # Step 1: Send the welcome emailCOMMENT
LOWexamples/python/welcome_email/worker.py45 # Step 2: Wait for the user to complete onboarding, or time outCOMMENT
LOWexamples/python/support_agent/worker.py131 # Step 1: Triage the ticketCOMMENT
LOWexamples/python/support_agent/worker.py134 # Step 2: Generate an initial replyCOMMENT
LOWexamples/python/support_agent/worker.py137 # Step 3: Wait for a customer reply or timeoutCOMMENT
LOWexamples/typescript/welcome_email/workflow.ts27 // Step 1: Send the welcome emailCOMMENT
4 more matches not shown…
Excessive Try-Catch Wrapping100 hits · 114 pts
SeverityFileLineSnippetContext
LOWsdks/python/apply_patches.py43 except Exception as e:CODE
MEDIUMsdks/python/apply_patches.py44 print(f"Error patching {file_path}: {e}")CODE
LOWsdks/python/tests/worker_fixture.py42 except Exception:CODE
MEDIUMsdks/python/tests/unit/test_durable_event_listener.py111def teardown(self) -> None:CODE
LOWsdks/python/tests/unit/test_durable_event_listener.py114 except Exception:CODE
LOWsdks/python/tests/unit/test_durable_event_listener.py119 except Exception:CODE
LOWsdks/python/tests/unit/test_instrumentor_signatures.py59 except Exception:CODE
LOWsdks/python/tests/unit/test_instrumentor_signatures.py66 except Exception:CODE
LOWsdks/python/tests/unit/test_shutdown_ordering.py269 except Exception:CODE
LOW…failure_on_timeout_with_multi_concurrency/test_case.py44 except Exception:CODE
LOW…pawn_cache_on_retry/test_child_spawn_cache_on_retry.py29 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/workflow_run.py94 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/clients/events.py170 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/clients/events.py415 except Exception:CODE
LOW…ks/python/hatchet_sdk/clients/dispatcher/dispatcher.py150 except Exception:CODE
LOW…ks/python/hatchet_sdk/clients/dispatcher/dispatcher.py280 except Exception:CODE
LOW…thon/hatchet_sdk/clients/dispatcher/action_listener.py161 except Exception:CODE
LOW…thon/hatchet_sdk/clients/dispatcher/action_listener.py215 except Exception:CODE
LOW…thon/hatchet_sdk/clients/dispatcher/action_listener.py354 except Exception:CODE
LOW…ython/hatchet_sdk/clients/listeners/pooled_listener.py155 except Exception as e:CODE
MEDIUM…ython/hatchet_sdk/clients/listeners/pooled_listener.py99def _init_producer(self) -> None:CODE
LOW…atchet_sdk/clients/listeners/durable_event_listener.py381 except Exception:CODE
LOW…atchet_sdk/clients/listeners/durable_event_listener.py387 except Exception as e:CODE
LOW…atchet_sdk/clients/listeners/durable_event_listener.py394 except Exception:CODE
LOWsdks/python/hatchet_sdk/clients/rest/exceptions.py132 except Exception:CODE
LOWsdks/python/hatchet_sdk/context/context.py499 except Exception:CODE
LOWsdks/python/hatchet_sdk/context/context.py558 except Exception:CODE
LOWsdks/python/hatchet_sdk/context/context.py576 except Exception:CODE
LOWsdks/python/hatchet_sdk/context/context.py596 except Exception:CODE
LOWsdks/python/hatchet_sdk/opentelemetry/instrumentor.py100 except Exception as exc:CODE
LOWsdks/python/hatchet_sdk/opentelemetry/instrumentor.py478 except Exception:CODE
LOWsdks/python/hatchet_sdk/opentelemetry/instrumentor.py869 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/opentelemetry/instrumentor.py1178 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/opentelemetry/instrumentor.py1243 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/runnables/action.py115 except Exception:CODE
LOWsdks/python/hatchet_sdk/runnables/workflow.py251 except Exception:CODE
LOWsdks/python/hatchet_sdk/runnables/workflow.py1217 except Exception as e:CODE
MEDIUMsdks/python/hatchet_sdk/worker/worker.py388def _setup_loop(self) -> None:CODE
MEDIUMsdks/python/hatchet_sdk/worker/worker.py593def _cleanup_lifespan(self) -> None:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py342 except Exception:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py353 except Exception:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py590 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py599 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py630 except Exception:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py659 except Exception:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py707 except Exception:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py726 except Exception:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py753 except Exception:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py764 except Exception:CODE
LOW…s/python/hatchet_sdk/worker/action_listener_process.py288 except Exception:CODE
LOW…s/python/hatchet_sdk/worker/action_listener_process.py315 except Exception:CODE
LOW…s/python/hatchet_sdk/worker/action_listener_process.py456 except Exception:CODE
LOW…s/python/hatchet_sdk/worker/action_listener_process.py515 except Exception:CODE
LOW…s/python/hatchet_sdk/worker/action_listener_process.py518 except Exception:CODE
LOW…s/python/hatchet_sdk/worker/action_listener_process.py614 except Exception:CODE
LOWsdks/python/hatchet_sdk/worker/runner/runner.py288 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/worker/runner/runner.py522 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/worker/runner/runner.py583 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/worker/runner/runner.py619 except Exception as e:CODE
LOWsdks/python/hatchet_sdk/worker/runner/runner.py674 except Exception as e:CODE
40 more matches not shown…
Verbosity Indicators40 hits · 81 pts
SeverityFileLineSnippetContext
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts9 // Step 1: Login as owner and create a tenantCOMMENT
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts64 // Step 2: Create an invite for the member userCOMMENT
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts84 // Step 4: Login as member (who has pending invite)COMMENT
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts108 // Step 5: Decline all invitesCOMMENT
LOW…nd/app/cypress/e2e/auth/08-tenant-invite-decline.cy.ts141 // Step 6: Verify the modal closes after all invites are declinedCOMMENT
LOWsdks/go/examples/dag/main.go31 // Step 1: Initial processingCOMMENT
LOWsdks/go/examples/dag/main.go41 // Step 2: Depends on step 1COMMENT
LOWsdks/go/examples/dag/main.go57 // Step 3: Also depends on step 1, parallel to step 2COMMENT
LOWsdks/go/examples/opentelemetry_instrumentation/main.go208 // Step 3: Send order confirmation (runs after both payment and inventory are done).COMMENT
LOWsdks/go/examples/with-workflows/main.go30 // Step 1: Initial processingCOMMENT
LOWsdks/go/examples/with-workflows/main.go38 // Step 2: Depends on step 1COMMENT
LOWsdks/go/examples/with-workflows/main.go52 // Step 3: Also depends on step 1, parallel to step 2COMMENT
LOWsdks/python/examples/welcome_email/worker.py43 # Step 1: Send the welcome emailCOMMENT
LOWsdks/python/examples/welcome_email/worker.py46 # Step 2: Wait for the user to complete onboarding, or time outCOMMENT
LOWsdks/python/examples/support_agent/worker.py135 # Step 1: Triage the ticketCOMMENT
LOWsdks/python/examples/support_agent/worker.py138 # Step 2: Generate an initial replyCOMMENT
LOWsdks/python/examples/support_agent/worker.py141 # Step 3: Wait for a customer reply or timeoutCOMMENT
LOW…s/typescript/src/v1/examples/welcome_email/workflow.ts28 // Step 1: Send the welcome emailCOMMENT
LOW…s/typescript/src/v1/examples/welcome_email/workflow.ts31 // Step 2: Wait for the user to complete onboarding, or time outCOMMENT
LOW…s/typescript/src/v1/examples/support_agent/workflow.ts123 // Step 1: Triage the ticketCOMMENT
LOW…s/typescript/src/v1/examples/support_agent/workflow.ts126 // Step 2: Generate an initial replyCOMMENT
LOW…s/typescript/src/v1/examples/support_agent/workflow.ts129 // Step 3: Wait for a customer reply or timeoutCOMMENT
LOWexamples/go/dag/main.go30 // Step 1: Initial processingCOMMENT
LOWexamples/go/dag/main.go39 // Step 2: Depends on step 1COMMENT
LOWexamples/go/dag/main.go54 // Step 3: Also depends on step 1, parallel to step 2COMMENT
LOWexamples/go/opentelemetry_instrumentation/main.go208 // Step 3: Send order confirmation (runs after both payment and inventory are done).COMMENT
LOWexamples/go/with-workflows/main.go30 // Step 1: Initial processingCOMMENT
LOWexamples/go/with-workflows/main.go38 // Step 2: Depends on step 1COMMENT
LOWexamples/go/with-workflows/main.go52 // Step 3: Also depends on step 1, parallel to step 2COMMENT
LOWexamples/python/welcome_email/worker.py42 # Step 1: Send the welcome emailCOMMENT
LOWexamples/python/welcome_email/worker.py45 # Step 2: Wait for the user to complete onboarding, or time outCOMMENT
LOWexamples/python/support_agent/worker.py131 # Step 1: Triage the ticketCOMMENT
LOWexamples/python/support_agent/worker.py134 # Step 2: Generate an initial replyCOMMENT
LOWexamples/python/support_agent/worker.py137 # Step 3: Wait for a customer reply or timeoutCOMMENT
LOWexamples/typescript/welcome_email/workflow.ts27 // Step 1: Send the welcome emailCOMMENT
LOWexamples/typescript/welcome_email/workflow.ts30 // Step 2: Wait for the user to complete onboarding, or time outCOMMENT
LOWexamples/typescript/support_agent/workflow.ts118 // Step 1: Triage the ticketCOMMENT
LOWexamples/typescript/support_agent/workflow.ts121 // Step 2: Generate an initial replyCOMMENT
LOWexamples/typescript/support_agent/workflow.ts124 // Step 3: Wait for a customer reply or timeoutCOMMENT
LOWpkg/repository/task.go3690 // we need to check if there are other steps in the subtreeCOMMENT
Redundant / Tautological Comments31 hits · 48 pts
SeverityFileLineSnippetContext
LOWsdks/python/apply_patches.py145 # Check if already patched with HTTPMethod enum supportCOMMENT
LOWsdks/python/apply_patches.py369 # Check if already using typed exceptions with HTTPMethod enumSTRING
LOWsdks/python/tests/worker_fixture.py67 # Check if the process is still runningCOMMENT
LOWsdks/ruby/src/spec/support/integration_helper.rb6 # Check if integration tests should be runCOMMENT
LOWsdks/ruby/src/lib/hatchet/clients.rb36 # Check if REST client is availableCOMMENT
LOWsdks/ruby/src/lib/hatchet/clients.rb42 # Check if this is the real implementation or just the placeholderCOMMENT
LOWsdks/ruby/src/lib/hatchet/context.rb106 # Check if a parent task was skippedCOMMENT
LOWsdks/ruby/src/lib/hatchet/context.rb164 # Check if the task has been cancelledCOMMENT
LOW…atchet/clients/rest/lib/hatchet-sdk-rest/api_client.rb249 # Check if the given MIME is a JSON MIME.COMMENT
LOW…het/clients/rest/lib/hatchet-sdk-rest/configuration.rb70 # 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.rb75 # Set this to enable/disable debugging. When enabled (set to true), HTTP request/responseCOMMENT
LOW…het/clients/rest/lib/hatchet-sdk-rest/configuration.rb82 # Set this to ignore operation servers for the API client. This is useful when you need toCOMMENT
LOW…het/clients/rest/lib/hatchet-sdk-rest/configuration.rb107 # Set this to false to skip client side validation in the operation.COMMENT
LOW…het/clients/rest/lib/hatchet-sdk-rest/configuration.rb113 # 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.rb129 # Set this to customize the certificate file to verify the peer.COMMENT
LOW…het/clients/rest/lib/hatchet-sdk-rest/configuration.rb146 # Set this to customize parameters encoder of array parameter.COMMENT
LOWsdks/ruby/src/lib/hatchet/features/runs.rb577 # Check if a workflow run status is terminal (completed)COMMENT
LOWsdks/ruby/src/lib/hatchet/worker/health_check.rb81 # Check if the server is runningCOMMENT
LOWsdks/ruby/src/lib/hatchet/worker/action_listener.rb97 # Check if connection was healthy long enough to reset retriesCOMMENT
LOWhack/install/install.sh63# Set trap to cleanup on exitCOMMENT
LOWhack/install/install.sh149 # Check if INSTALL_DIR is already set via environment variableCOMMENT
LOWhack/install/install.sh162 # Check if ~/.local/bin is in PATH and is/can be writableCOMMENT
LOWhack/install/install.sh183 # Check if we'll need sudoCOMMENT
LOWhack/install/install.sh338 # Check if we need sudoCOMMENT
LOWhack/dev/start-dev-tmux.sh7# Check if tmux is installedCOMMENT
LOWhack/dev/compression-test/scripts/run_test.sh53# Check if client image existsCOMMENT
LOWhack/dev/compression-test/scripts/monitor_network.sh100 # Check if we got valid stats (not empty and not just "0B / 0B")COMMENT
LOWhack/dev/compression-test/scripts/monitor_network.sh165 # Check if container still exists - if not, break early but still write summaryCOMMENT
LOWhack/dev/compression-test/scripts/monitor_network.sh183 # Check if container exists (running or stopped)COMMENT
LOWhack/dev/compression-test/scripts/monitor_network.sh212# Check if bc is available, if not use awk for calculationsCOMMENT
LOW.github/workflows/gen-examples.yml39 # Check if there are any changesCOMMENT
Fake / Example Data33 hits · 38 pts
SeverityFileLineSnippetContext
LOWcmd/hatchet-admin/cli/seed/seed-cypress.go59 email: "admin@example.com",CODE
LOWcmd/hatchet-cli/cli/server.go221 lines = append(lines, styles.Muted.Render("Admin credentials: email 'admin@example.com', password 'Admin123!!'"))CODE
LOWfrontend/app/src/lib/free-email-domains.json937 "fake-email.pp.ua",CODE
LOW…ain/v1/workflow-runs-v1/$run/v2components/mini-map.tsx48 const node = shapeItem.stepId ?? 'placeholder';CODE
LOWsdks/go/examples/events/main.go58 "email": "user@example.com",CODE
LOWsdks/go/examples/events/main.go59 "name": "John Doe",CODE
LOWsdks/go/examples/events/main.go73 "name": "John Doe",CODE
LOWsdks/python/examples/cron/programatic-async.py21 input=DynamicCronInput(name="John Doe"),CODE
LOWsdks/python/examples/cron/programatic-sync.py20 input=DynamicCronInput(name="John Doe"),CODE
LOW…egacy/examples/scheduled-runs/programatic-schedules.ts17 name: 'John Doe',CODE
LOW…escript/src/legacy/examples/crons/programatic-crons.ts18 name: 'John Doe',CODE
LOWsdks/ruby/examples/cron/programatic_sync.rb13 input: { "name" => "John Doe" }CODE
LOWsdks/ruby/src/lib/hatchet/features/events.rb85 # { user_id: 456, email: "user@example.com" },COMMENT
LOWexamples/go/guides/human-in-the-loop/main.go45 proposedAction := map[string]string{"action": "send_email", "to": "user@example.com"}CODE
LOWexamples/go/events/main.go58 "email": "user@example.com",CODE
LOWexamples/go/events/main.go59 "name": "John Doe",CODE
LOWexamples/go/events/main.go73 "name": "John Doe",CODE
LOWexamples/python/cron/programatic-async.py21 input=DynamicCronInput(name="John Doe"),CODE
LOWexamples/python/cron/programatic-sync.py20 input=DynamicCronInput(name="John Doe"),CODE
LOWexamples/ruby/guides/human_in_the_loop/worker.rb23 proposed_action = { 'action' => 'send_email', 'to' => 'user@example.com' }CODE
LOWexamples/ruby/cron/programatic_sync.rb13 input: { "name" => "John Doe" }CODE
LOWpkg/config/database/config.go59 AdminEmail string `mapstructure:"adminEmail" json:"adminEmail,omitempty" default:"admin@example.com"`CODE
LOWpkg/integrations/email/smtp/smtp_test.go43 expectedRecipients: []string{"user@example.com"},CODE
LOWpkg/integrations/email/smtp/smtp_test.go45 TenantName: "Acme Corp",CODE
LOWpkg/integrations/email/smtp/smtp_test.go51 ctx, "user@example.com", d.(email.TenantInviteEmailData),CODE
LOWpkg/integrations/email/smtp/smtp_test.go61 TenantName: "Acme Corp",CODE
LOWpkg/integrations/email/smtp/smtp_test.go76 expectedRecipients: []string{"admin@example.com"},CODE
LOWpkg/integrations/email/smtp/smtp_test.go78 TenantName: "Acme Corp",CODE
LOWpkg/integrations/email/smtp/smtp_test.go87 ctx, []string{"admin@example.com"}, d.(email.ExpiringTokenEmailData),CODE
LOWpkg/integrations/email/smtp/smtp_test.go96 expectedRecipients: []string{"admin@example.com", testSupportEmail},CODE
LOWpkg/integrations/email/smtp/smtp_test.go98 TenantName: "Acme Corp",CODE
LOWpkg/integrations/email/smtp/smtp_test.go109 ctx, []string{"admin@example.com"}, d.(email.ResourceLimitAlertData),CODE
LOWpkg/integrations/email/smtp/smtp_test.go156 err := service.SendTenantInviteEmail(context.Background(), "user@example.com", email.TenantInviteEmailData{CODE
Deep Nesting36 hits · 35 pts
SeverityFileLineSnippetContext
LOWfrontend/snippets/generate.py189CODE
LOWfrontend/snippets/generate.py235CODE
LOWsdks/python/hatchet_sdk/clients/admin.py414CODE
LOWsdks/python/hatchet_sdk/clients/admin.py459CODE
LOWsdks/python/hatchet_sdk/clients/admin.py532CODE
LOWsdks/python/hatchet_sdk/clients/admin.py606CODE
LOW…thon/hatchet_sdk/clients/dispatcher/action_listener.py78CODE
LOW…thon/hatchet_sdk/clients/dispatcher/action_listener.py152CODE
LOW…on/hatchet_sdk/clients/listeners/run_event_listener.py148CODE
LOW…ython/hatchet_sdk/clients/listeners/pooled_listener.py99CODE
LOW…atchet_sdk/clients/listeners/durable_event_listener.py346CODE
LOW…atchet_sdk/clients/listeners/durable_event_listener.py397CODE
LOWsdks/python/hatchet_sdk/clients/rest/rest.py120CODE
LOWsdks/python/hatchet_sdk/clients/rest/api_client.py272CODE
LOWsdks/python/hatchet_sdk/clients/rest/api_client.py330CODE
LOWsdks/python/hatchet_sdk/clients/rest/api_client.py430CODE
LOWsdks/python/hatchet_sdk/clients/rest/api_client.py475CODE
LOWsdks/python/hatchet_sdk/clients/rest/api_client.py504CODE
LOWsdks/python/hatchet_sdk/clients/rest/api_client.py543CODE
LOWsdks/python/hatchet_sdk/runnables/task.py324CODE
LOWsdks/python/hatchet_sdk/runnables/task.py369CODE
LOWsdks/python/hatchet_sdk/runnables/task.py422CODE
LOWsdks/python/hatchet_sdk/worker/worker.py634CODE
LOWsdks/python/hatchet_sdk/worker/worker.py710CODE
LOW…s/python/hatchet_sdk/worker/action_listener_process.py390CODE
LOWsdks/python/hatchet_sdk/worker/runner/runner.py472CODE
LOWsdks/python/hatchet_sdk/worker/runner/runner.py655CODE
LOW…python/hatchet_sdk/worker/runner/utils/capture_logs.py87CODE
LOWsdks/python/hatchet_sdk/deprecated/worker.py224CODE
LOW…thon/hatchet_sdk/deprecated/action_listener_process.py348CODE
LOWsdks/python/examples/pdf_pipeline/worker.py105CODE
LOW…ment/test_worker_shutdown_no_premature_reassignment.py29CODE
LOWhack/db/generate-oss-db-model.py97CODE
LOWhack/db/generate-oss-db-model.py132CODE
LOWhack/db/generate-oss-db-model.py171CODE
LOWexamples/python/pdf_pipeline/worker.py102CODE
Modern AI Meta-Vocabulary6 hits · 18 pts
SeverityFileLineSnippetContext
MEDIUMREADME.md9### An orchestration engine for background tasks, AI agents, and durable workflowsCOMMENT
MEDIUMREADME.md64#### Task orchestration and workflowsCOMMENT
MEDIUMfrontend/docs/guides/STEP_SCHEMA.md30## event-drivenCOMMENT
MEDIUMfrontend/docs/guides/STEP_SCHEMA.md76## multi-agentCOMMENT
MEDIUMsdks/ruby/src/lib/hatchet-sdk.rb117 # event-driven workflows.COMMENT
MEDIUMsdks/ruby/src/lib/hatchet/features/events.rb44 # processed and made available for workflow triggers and event-driven automation.COMMENT
Modern Structural Boilerplate15 hits · 15 pts
SeverityFileLineSnippetContext
LOWsdks/python/docs/generator/generate.py137def update_meta_json(documents: list[Document]) -> None:CODE
LOWsdks/python/hatchet_sdk/labels.py3__all__ = ["DesiredWorkerLabel", "WorkerLabel"]CODE
LOWsdks/python/hatchet_sdk/__init__.py206__all__ = [CODE
LOWsdks/python/hatchet_sdk/rate_limit.py3__all__ = ["RateLimit", "RateLimitDuration"]CODE
LOWsdks/python/hatchet_sdk/clients/rest/configuration.py361 def set_default(cls, default: Optional[Self]) -> None:CODE
LOWsdks/python/hatchet_sdk/types/__init__.py15__all__ = [CODE
LOWsdks/python/hatchet_sdk/context/context.py416 def _set_cancellation_flag(self) -> None:CODE
LOWsdks/python/hatchet_sdk/utils/priority.py3__all__ = ["Priority", "_warn_if_int_priority"]CODE
LOWsdks/python/hatchet_sdk/worker/worker.py388 def _setup_loop(self) -> None:CODE
LOWsdks/python/hatchet_sdk/worker/worker.py662 def _setup_signal_handlers(self) -> None:CODE
LOWsdks/python/hatchet_sdk/worker/slot_types.py3__all__ = ["SlotType"]CODE
LOW…python/hatchet_sdk/worker/durable_eviction/__init__.py8__all__ = [CODE
LOWsdks/python/hatchet_sdk/serde/__init__.py6__all__ = [CODE
LOWsdks/python/examples/logger/workflow.py9logger = logging.getLogger(__name__)CODE
LOWexamples/python/logger/workflow.py9logger = logging.getLogger(__name__)CODE
Magic Placeholder Names2 hits · 10 pts
SeverityFileLineSnippetContext
HIGHsdks/go/examples/webhooks/main.go167 APIKey: "your-api-key",CODE
HIGHexamples/go/webhooks/main.go162 APIKey: "your-api-key",CODE
Hallucination Indicators1 hit · 10 pts
SeverityFileLineSnippetContext
CRITICALsdks/python/hatchet_sdk/runnables/workflow.py2567 wrr = self._workflow.client._client.runs.get_run_ref(run_id)CODE
Example Usage Blocks5 hits · 8 pts
SeverityFileLineSnippetContext
LOWsdks/go/client.go885// Example usage:COMMENT
LOWsdks/go/client.go924// Example usage:COMMENT
LOWsdks/ruby/generate.sh9# Usage:COMMENT
LOWhack/update-go-quickstart-deps.sh22# Usage:COMMENT
LOWhack/install/install.sh6# Usage:COMMENT
Slop Phrases2 hits · 6 pts
SeverityFileLineSnippetContext
MEDIUMsdks/ruby/src/lib/hatchet-sdk.rb116 # The events client, which you can use to push events to Hatchet to triggerCOMMENT
MEDIUM…/ruby/src/lib/hatchet/clients/rest/spec/spec_helper.rb59# with RSpec, but feel free to customize to your heart's content.COMMENT
Cross-Language Confusion (JS/TS)1 hit · 5 pts
SeverityFileLineSnippetContext
HIGH…/pages/main/v1/managed-workers/demo-template/index.tsx307print(result)CODE
Overly Generic Function Names2 hits · 2 pts
SeverityFileLineSnippetContext
LOW…ython/examples/opentelemetry_instrumentation/worker.py76def process_data(input: EmptyModel, ctx: Context) -> ProcessDataOutput:CODE
LOWexamples/python/opentelemetry_instrumentation/worker.py76def process_data(input: EmptyModel, ctx: Context) -> ProcessDataOutput:CODE