Repository Analysis

PrefectHQ/prefect

Prefect is a workflow orchestration framework for building resilient data pipelines in Python.

22.7 Moderate AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of PrefectHQ/prefect, a Python project with 23,341 GitHub stars. SynthScan v2.0 examined 924,219 lines of code across 3816 source files, recording 18445 pattern matches distributed across 23 syntactic categories. The overall adjusted score of 22.7 places this repository in the Moderate 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).

22.7
Adjusted Score
22.7
Raw Score
100%
Time Factor
2026-07-13
Last Push
23.3K
Stars
Python
Language
924.2K
Lines of Code
3.8K
Files
18.4K
Pattern Hits
2026-07-14
Scan Date
0.18
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 31HIGH 653MEDIUM 815LOW 16946

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 18445 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.

Hyper-Verbose Identifiers13961 hits · 11869 pts
SeverityFileLineSnippetContext
LOWhatch_build.py27def should_validate_packaged_ui_index_files(root: str | Path) -> bool:CODE
LOWhatch_build.py38def validate_packaged_ui_index_files(root: str | Path) -> None:CODE
LOWui/src/types/automation.ts32export function isAutomationActionFormValues(value: AutomationFormValues): value is AutomationActionFormValues {CODE
LOWui/src/components/AutomationWizardStepTrigger.vue67 function updateTriggerFromJsonString(): AutomationTrigger {CODE
LOWui/src/services/apiStatus.ts12export function setupApiStatusInterceptor(axiosInstance: AxiosInstance): void {CODE
LOWplans/2026-01-12-deployment-crud-events.md140async def _deployment_related_resources(CODE
LOWplans/2026-01-12-deployment-crud-events.md165async def emit_deployment_created_event(CODE
LOWplans/2026-01-12-deployment-crud-events.md179async def emit_deployment_updated_event(CODE
LOWplans/2026-01-12-deployment-crud-events.md197async def emit_deployment_deleted_event(CODE
LOWplans/2025-01-31-per-node-dbt-orchestration.md386def compute_freshness_expiration(CODE
LOWplans/completed/2026-02-18-runner-refactor.md256 def propose_awaiting_retry_sync(self, flow_run: FlowRun) -> None: ...CODE
LOWplans/completed/2026-02-18-runner-refactor.md546 def reschedule_current_flow_runs(self) -> None: ... # sync — uses snapshot(), sync clientCODE
LOWplans/completed/2026-02-18-runner-refactor.md583 async def _run_on_cancellation_hooks(self, flow_run: "FlowRun", state: "State") -> None: ...CODE
LOWplans/completed/2026-02-18-runner-refactor.md592 async def _get_and_submit_flow_runs(self) -> None: ... # → _scheduled_run_poller._get_and_submCODE
LOWplans/completed/2026-02-18-runner-refactor.md595 async def _mark_flow_run_as_cancelled(self, flow_run: "FlowRun", state_updates: "dict[str, Any] | None" = None) -> NCODE
LOWplans/completed/2026-02-18-runner-refactor.md596 async def _handle_cancellation_observer_failure(self) -> None: ...CODE
LOWtests/conftest.py163def pytest_collection_modifyitems(CODE
LOWtests/conftest.py266async def restore_loop_after_each_test():CODE
LOWtests/conftest.py296def assert_lifespan_is_not_left_open():CODE
LOWtests/conftest.py424async def generate_test_database_connection_url(CODE
LOWtests/conftest.py506def test_database_connection_url(STRING
LOWtests/conftest.py619def leaves_no_extraneous_files():STRING
LOWtests/test_serializers.py403 def test_does_not_allow_object_hook_collision(self):STRING
LOWtests/test_serializers.py407 def test_does_not_allow_default_collision(self):STRING
LOWtests/test_serializers.py411 def test_pydantic_generic_model_roundtrip(self):STRING
LOWtests/test_serializers.py455 def test_exc_type_rejects_non_exception_class(self):STRING
LOWtests/test_serializers.py461 def test_exc_type_allows_real_exception(self):STRING
LOWtests/test_serializers.py468 def test_exc_type_raises_on_unimportable_class(self):STRING
LOWtests/test_serializers.py474 def test_exc_type_raises_on_dotless_name(self):STRING
LOWtests/test_serializers.py478 def test_class_path_handles_unimportable_class(self):STRING
LOWtests/test_serializers.py484 def test_class_path_handles_dotless_name(self):STRING
LOWtests/test_serializers.py88 def restore_dispatch_registry(self):STRING
LOWtests/test_serializers.py98 def test_serializers_do_not_allow_extra_fields(self):STRING
LOWtests/test_serializers.py111 def test_serializers_can_be_created_by_dict(self):STRING
LOWtests/test_serializers.py127 def test_serializers_can_be_created_by_object(self):STRING
LOWtests/test_serializers.py143 def test_serializers_can_be_created_by_type_string(self):STRING
LOWtests/test_serializers.py165 def test_unknown_serializers_raise_validation_error(self):STRING
LOWtests/test_serializers.py184 def test_simple_roundtrip_with_builtin_pickle(self, data):STRING
LOWtests/test_serializers.py189 def test_picklelib_must_be_string(self):STRING
LOWtests/test_serializers.py206 def test_picklelib_must_implement_dumps(self, monkeypatch: pytest.MonkeyPatch):STRING
LOWtests/test_serializers.py216 def test_picklelib_must_implement_loads(self, monkeypatch: pytest.MonkeyPatch):STRING
LOWtests/test_serializers.py250 def test_simple_roundtrip_with_complex_bytes(self, data: Any):STRING
LOWtests/test_serializers.py263 def test_uses_alternative_json_library(self, monkeypatch: pytest.MonkeyPatch):STRING
LOWtests/test_serializers.py276 def test_json_serializer_does_not_consume_iobase_objects(self):STRING
LOWtests/test_serializers.py337 def test_allows_custom_encoder(self, monkeypatch: pytest.MonkeyPatch):STRING
LOWtests/test_serializers.py362 def test_allows_custom_decoder(self, monkeypatch: pytest.MonkeyPatch):STRING
LOWtests/test_serializers.py386 def test_allows_custom_kwargs(self, monkeypatch: pytest.MonkeyPatch):STRING
LOWtests/test_serializers.py437 def test_dataclass_generic_model_roundtrip(self):STRING
LOWtests/test_serializers.py497 def test_allows_stdlib_compression_libraries(self, lib):STRING
LOWtests/test_serializers.py502 def test_uses_alternative_compression_library(STRING
LOWtests/test_serializers.py515 def test_uses_given_serializer(self, monkeypatch: pytest.MonkeyPatch):STRING
LOWtests/test_infrastructure_bound_flow.py60 def mock_subprocess_check_call(self, monkeypatch: pytest.MonkeyPatch):CODE
LOWtests/test_infrastructure_bound_flow.py113 async def work_pool_without_default_result_storage(CODE
LOWtests/test_infrastructure_bound_flow.py145 async def work_pool_missing_storage_configuration(CODE
LOWtests/test_infrastructure_bound_flow.py160 def test_bind_flow_to_infrastructure(CODE
LOWtests/test_infrastructure_bound_flow.py178 def dragged_through_the_garden():CODE
LOWtests/test_infrastructure_bound_flow.py292 def test_bind_flow_to_infrastructure_normalizes_launcher(CODE
LOWtests/test_infrastructure_bound_flow.py311 def test_bind_flow_to_infrastructure_rejects_invalid_launcher_keys(CODE
LOWtests/test_infrastructure_bound_flow.py329 def test_bind_flow_to_infrastructure_rejects_empty_launcher_override(CODE
LOWtests/test_infrastructure_bound_flow.py344 def test_with_options_preserves_launcher_when_not_provided(CODE
13901 more matches not shown…
Docstring Block Structure309 hits · 1525 pts
SeverityFileLineSnippetContext
HIGHplans/2026-01-06-custom-deployment-sdks.md621Get a deployment by name. Args: name: The deployment name in "flow-name/deployment-name" format. STRING
HIGHtests/_internal/compatibility/test_migration.py10 Import an object from a dotted path. This function dynamically imports an object (such as a class, function, oSTRING
HIGHtests/runner/test_storage.py125 Format and return the full git URL with GitLab credentials embedded. Handles both personal access tokeSTRING
HIGH…integrations/prefect-dbt/prefect_dbt/core/_manifest.py345Get the resolved dependencies for a specific node. Args: node_id: The unique_id of the node STRING
HIGH…integrations/prefect-dbt/prefect_dbt/core/_manifest.py365Compute execution waves using Kahn's algorithm. Each wave contains nodes that can be executed in parallel. STRING
HIGH…integrations/prefect-dbt/prefect_dbt/core/_manifest.py548Resolve dbt selectors to a set of node unique_ids. Uses `dbt ls` under the hood, so all of dbt's selector syntax isSTRING
HIGH…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1104Execute a dbt build wave-by-wave or per-node. Pipeline: 1. Parse the manifest 2. Optionally resSTRING
HIGH…ntegrations/prefect-dbt/prefect_dbt/core/_freshness.py64Convert a dbt freshness period specification to a timedelta. Args: count: Number of periods period:STRING
HIGH…ntegrations/prefect-dbt/prefect_dbt/core/_artifacts.py224Create a Prefect `Asset` from a `DbtNode`. Args: node: The DbtNode to create an asset for. Must have a STRING
HIGH…integrations/prefect-dbt/prefect_dbt/core/_executor.py691Execute a wave of nodes using `dbt build`. Uses `dbt build` to handle mixed resource types in a single invocatiSTRING
HIGH…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py167 Task for running dbt commands. If no profiles.yml file is found or if overwrite_profiles flag is set to True, STRING
HIGH…tegrations/prefect-dbt/prefect_dbt/cli/configs/base.py176 Create a TargetConfigs instance from a dbt profiles.yml file. Args: profile_name: Name of STRING
HIGHsrc/integrations/prefect-dbt/prefect_dbt/cloud/jobs.py382 A task to trigger a dbt Cloud job run. Args: dbt_cloud_credentials: Credentials for authenticating witSTRING
HIGHsrc/integrations/prefect-dbt/prefect_dbt/cloud/jobs.py531 Flow that triggers a job run and waits for the triggered run to complete. Args: dbt_cloud_credentials:STRING
HIGHsrc/integrations/prefect-dbt/prefect_dbt/cloud/jobs.py836 Flow that retrys a subset of dbt Cloud job run, filtered by select statuses, and waits for the triggered retry STRING
HIGHsrc/integrations/prefect-dbt/prefect_dbt/cloud/utils.py62 Task that calls a specified endpoint in the dbt Cloud administrative API. Use this task if a prebuilt one is noSTRING
HIGH…ntegrations/prefect-dbt/prefect_dbt/cloud/_executor.py179Poll a run until it reaches a terminal status. Args: run_id: dbt Cloud run ID to poll. RetSTRING
HIGH…ntegrations/prefect-dbt/prefect_dbt/cloud/_executor.py472Execute a wave of dbt nodes via an ephemeral dbt Cloud job. Uses `dbt build --select sel1 sel2 ...` to execute STRING
HIGHsrc/integrations/prefect-dbt/prefect_dbt/cloud/runs.py165 A task to get an artifact generated for a completed run. The requested artifact is saved to a file in the curreSTRING
HIGHsrc/integrations/prefect-dbt/prefect_dbt/cloud/runs.py256 Waits for the given dbt Cloud job run to finish running. Args: run_id: The ID of the run to wait for. STRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1505 Creates a bucket (async version). Args: location: The location of the bucket. STRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1536 Creates a bucket. Args: location: The location of the bucket. **create_kwargs:STRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1603 Lists all blobs in the bucket that are in a folder (async version). Folders are not included in the outSTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1640 Lists all blobs in the bucket that are in a folder. Folders are not included in the output. ArSTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1668 Lists all folders and subfolders in the bucket (async version). Args: folder: List all folSTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1713 Lists all folders and subfolders in the bucket. Args: folder: List all folders and subfoldSTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1751 Downloads an object from the object storage service to a path (async version). Args: from_STRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1801 Downloads an object from the object storage service to a path. Args: from_path: The path tSTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1842 Downloads an object from the object storage service to a file-like object (async version), which can beSTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1897 Downloads an object from the object storage service to a file-like object, which can be a BytesIO objecSTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1945 Downloads objects *within* a folder (excluding the folder itself) from the object storage service to a STRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2013 Downloads objects *within* a folder (excluding the folder itself) from the object storage service to a STRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2067 Uploads an object from a path to the object storage service (async version). Args: from_paSTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2113 Uploads an object from a path to the object storage service. Args: from_path: The path to STRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2149 Uploads an object to the object storage service from a file-like object (async version), which can be aSTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2204 Uploads an object to the object storage service from a file-like object, which can be a BytesIO object STRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2255 Uploads files *within* a folder (excluding the folder itself) to the object storage service folder (asySTRING
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2315 Uploads files *within* a folder (excluding the folder itself) to the object storage service folder. STRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/credentials.py243 Helper method to dynamically get a client type. Args: client_type: The name of the client STRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/credentials.py267 Gets an authenticated Cloud Storage client. Args: project: Name of the project to use; oveSTRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/credentials.py328 Gets an authenticated BigQuery client. Args: project: Name of the project to use; overrideSTRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1096 Fetch a single result from the database (async version). Repeated calls using the same inputs to *any*STRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1155 Fetch a single result from the database. Repeated calls using the same inputs to *any* of the fetch meSTRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1213 Fetch a limited number of results from the database (async version). Repeated calls using the same inpSTRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1280 Fetch a limited number of results from the database. Repeated calls using the same inputs to *any* of STRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1344 Fetch all results from the database (async version). Repeated calls using the same inputs to *any* of STRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1401 Fetch all results from the database. Repeated calls using the same inputs to *any* of the fetch methodSTRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1456 Executes an operation on the database (async version). This method is intended to be used for operationSTRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1504 Executes an operation on the database. This method is intended to be used for operations that do not reSTRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1549 Executes many operations on the database (async version). This method is intended to be used for operatSTRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1601 Executes many operations on the database. This method is intended to be used for operations that do notSTRING
HIGH…ations/prefect-gcp/prefect_gcp/workers/cloud_run_v2.py1050 Check whether a transient submission error actually started an execution. Submitting a Cloud Run job iSTRING
HIGH…ations/prefect-gcp/prefect_gcp/workers/cloud_run_v2.py1311 Update execution status until it is no longer running. Args: cr_client (Resource): The basSTRING
HIGH…egrations/prefect-gcp/prefect_gcp/deployments/steps.py41 Pushes the contents of the current working directory to a GCS bucket, excluding files and folders specified in STRING
HIGH…egrations/prefect-gcp/prefect_gcp/deployments/steps.py145 Pulls the contents of a project from an GCS bucket to the current working directory. Args: bucket: TheSTRING
HIGH…refect-kubernetes/prefect_kubernetes/custom_objects.py139Task for reading a namespaced Kubernetes custom object. Args: kubernetes_credentials: `KubernetesCredentialSTRING
HIGH…refect-kubernetes/prefect_kubernetes/custom_objects.py313Task for patching a namespaced custom resource. Args: kubernetes_credentials: KubernetesCredentials block STRING
HIGH…refect-kubernetes/prefect_kubernetes/custom_objects.py386Task for replacing a namespaced custom resource. Args: kubernetes_credentials: KubernetesCredentials block STRING
HIGH…s/prefect-kubernetes/prefect_kubernetes/credentials.py205 Utility function for configuring a generic Kubernetes client. It will attempt to connect to a KuberneteSTRING
HIGH…grations/prefect-kubernetes/prefect_kubernetes/jobs.py174Task for patching a namespaced Kubernetes job. Args: kubernetes_credentials: KubernetesCredentials block STRING
249 more matches not shown…
Decorative Section Separators375 hits · 1402 pts
SeverityFileLineSnippetContext
MEDIUMplans/completed/2026-02-18-runner-refactor.md560 # ── Internal attributes — tests access these directly ────────────────────────COMMENT
MEDIUMplans/completed/2026-02-18-runner-refactor.md576 # ── Private method passthroughs ──────────────────────────────────────────────COMMENT
MEDIUMtests/test_assets.py286# =============================================================================COMMENT
MEDIUMtests/test_assets.py288# =============================================================================COMMENT
MEDIUMtests/test_assets.py389# =============================================================================COMMENT
MEDIUMtests/test_assets.py391# =============================================================================COMMENT
MEDIUMtests/test_assets.py450# =============================================================================COMMENT
MEDIUMtests/test_assets.py452# =============================================================================COMMENT
MEDIUMtests/test_assets.py1045# =============================================================================COMMENT
MEDIUMtests/test_assets.py1047# =============================================================================COMMENT
MEDIUMtests/test_assets.py1230# =============================================================================COMMENT
MEDIUMtests/test_assets.py1232# =============================================================================COMMENT
MEDIUMtests/test_assets.py1312# =============================================================================COMMENT
MEDIUMtests/test_assets.py1314# =============================================================================COMMENT
MEDIUMtests/test_assets.py1412# =============================================================================COMMENT
MEDIUMtests/test_assets.py1414# =============================================================================COMMENT
MEDIUMtests/test_assets.py52# =============================================================================COMMENT
MEDIUMtests/test_assets.py54# =============================================================================COMMENT
MEDIUMtests/test_assets.py678# =============================================================================COMMENT
MEDIUMtests/test_assets.py680# =============================================================================COMMENT
MEDIUMtests/test_subprocess_logging.py15# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_subprocess_logging.py17# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_subprocess_logging.py44# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/test_subprocess_logging.py46# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py92# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py94# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py136# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py138# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py197# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py199# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py268# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py270# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py297# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py299# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py525# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py527# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py543# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py545# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py599# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py601# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py679# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py681# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py14# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__scheduled_run_poller.py16# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__flow_run_executor.py147# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__flow_run_executor.py149# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__flow_run_executor.py444# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__flow_run_executor.py446# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__flow_run_executor.py18# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/runner/test__flow_run_executor.py20# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/server/services/test_db_vacuum.py165# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/server/services/test_db_vacuum.py167# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/server/services/test_db_vacuum.py54# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/server/services/test_db_vacuum.py56# ---------------------------------------------------------------------------COMMENT
MEDIUMtests/events/server/triggers/test_flow_run_slas.py810# ------------------------------------------------------COMMENT
MEDIUM…ents/server/actions/test_pausing_resuming_work_pool.py324# -----------------------------------------------------COMMENT
MEDIUM…ents/server/actions/test_pausing_resuming_work_pool.py330# -----------------------------------------------------COMMENT
MEDIUMexamples/run_api_sourced_etl.py67# ---------------------------------------------------------------------------COMMENT
MEDIUMexamples/run_api_sourced_etl.py69# ---------------------------------------------------------------------------COMMENT
MEDIUMexamples/run_api_sourced_etl.py83# ---------------------------------------------------------------------------COMMENT
315 more matches not shown…
Cross-File Repetition277 hits · 1385 pts
SeverityFileLineSnippetContext
HIGHtests/test_task_worker.py0tests for the sync_compatible to async_dispatch migration.STRING
HIGHtests/blocks/test_core.py0tests for the sync_compatible to async_dispatch migration.STRING
HIGHtests/concurrency/v1/test_concurrency_sync.py0tests for the sync_compatible to async_dispatch migration.STRING
HIGHtests/test_flows.py0\ from prefect import flow @flow def test_flow(): return 1STRING
HIGHtests/runner/test_storage.py0\ from prefect import flow @flow def test_flow(): return 1STRING
HIGHtests/runner/test_runner.py0\ from prefect import flow @flow def test_flow(): return 1STRING
HIGHtests/deployment/test_steps.py0\ from prefect import flow @flow def test_flow(): return 1STRING
HIGHtests/test_filesystems.py0add files and directories to a temporary directory. returns a tuple with the expected parent-level contents and the expeSTRING
HIGH…c/integrations/prefect-github/tests/test_repository.py0add files and directories to a temporary directory. returns a tuple with the expected parent-level contents and the expeSTRING
HIGH…integrations/prefect-gitlab/tests/test_repositories.py0add files and directories to a temporary directory. returns a tuple with the expected parent-level contents and the expeSTRING
HIGH…ntegrations/prefect-bitbucket/tests/test_repository.py0add files and directories to a temporary directory. returns a tuple with the expected parent-level contents and the expeSTRING
HIGHtests/server/database/test_migrations.py0flow run {{ flow.name }}/{{ flow_run.name }} observed in state `{{ flow_run.state.name }}` at {{ flow_run.state.timestamSTRING
HIGH…9_112902_4160a4841eed_remove_flow_run_notifications.py0flow run {{ flow.name }}/{{ flow_run.name }} observed in state `{{ flow_run.state.name }}` at {{ flow_run.state.timestamSTRING
HIGH…8_133722_7655f31c5157_remove_flow_run_notifications.py0flow run {{ flow.name }}/{{ flow_run.name }} observed in state `{{ flow_run.state.name }}` at {{ flow_run.state.timestamSTRING
HIGHtests/server/database/test_queries.py0creates: - three different work pools ("a", "b", "c") - three different queues in each pool ("aa", "ab", "ac", "ba", "bbSTRING
HIGHtests/server/models/test_workers.py0creates: - three different work pools ("a", "b", "c") - three different queues in each pool ("aa", "ab", "ac", "ba", "bbSTRING
HIGHtests/server/orchestration/api/test_workers.py0creates: - three different work pools ("a", "b", "c") - three different queues in each pool ("aa", "ab", "ac", "ba", "bbSTRING
HIGHtests/server/api/test_logs_text_search.py0opens an appropriate session for the backend, seeds it with the test events, and returns it for use in testsSTRING
HIGHtests/events/test_events_text_search.py0opens an appropriate session for the backend, seeds it with the test events, and returns it for use in testsSTRING
HIGHtests/events/server/test_events_counts.py0opens an appropriate session for the backend, seeds it with the test events, and returns it for use in testsSTRING
HIGHtests/server/api/test_logs_websocket.py0when auth is not configured, old clients without prefect subprotocol are accepted.STRING
HIGHtests/events/server/gateway/test_gateway_out.py0when auth is not configured, old clients without prefect subprotocol are accepted.STRING
HIGHtests/events/server/gateway/test_gateway_in.py0when auth is not configured, old clients without prefect subprotocol are accepted.STRING
HIGHtests/cli/transfer/test_work_pools.py0test that construct returns cached instance for same id.STRING
HIGHtests/cli/transfer/test_flows.py0test that construct returns cached instance for same id.STRING
HIGHtests/cli/transfer/test_concurrency_limits.py0test that construct returns cached instance for same id.STRING
HIGHtests/cli/transfer/test_blocks.py0test that construct returns cached instance for same id.STRING
HIGHtests/cli/transfer/test_work_queues.py0test that construct returns cached instance for same id.STRING
HIGHtests/cli/transfer/test_automations.py0test that construct returns cached instance for same id.STRING
HIGHtests/cli/transfer/test_variables.py0test that construct returns cached instance for same id.STRING
HIGHtests/cli/transfer/test_deployments.py0test that construct returns cached instance for same id.STRING
HIGHtests/cli/transfer/test_work_pools.py0test that get_instance returns none for unknown id.STRING
HIGHtests/cli/transfer/test_flows.py0test that get_instance returns none for unknown id.STRING
HIGHtests/cli/transfer/test_concurrency_limits.py0test that get_instance returns none for unknown id.STRING
HIGHtests/cli/transfer/test_blocks.py0test that get_instance returns none for unknown id.STRING
HIGHtests/cli/transfer/test_work_queues.py0test that get_instance returns none for unknown id.STRING
HIGHtests/cli/transfer/test_automations.py0test that get_instance returns none for unknown id.STRING
HIGHtests/cli/transfer/test_variables.py0test that get_instance returns none for unknown id.STRING
HIGHtests/cli/transfer/test_deployments.py0test that get_instance returns none for unknown id.STRING
HIGHtests/cli/transfer/test_work_pools.py0test that dependencies are cached after first call.STRING
HIGHtests/cli/transfer/test_work_queues.py0test that dependencies are cached after first call.STRING
HIGHtests/cli/transfer/test_automations.py0test that dependencies are cached after first call.STRING
HIGHtests/cli/transfer/test_deployments.py0test that dependencies are cached after first call.STRING
HIGHsrc/integrations/prefect-dbt/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-kubernetes/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-github/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-snowflake/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-dask/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-docker/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-gitlab/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-sqlalchemy/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-shell/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-bitbucket/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-databricks/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-redis/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-azure/tests/conftest.py0sets up test harness for temporary db during test runs.STRING
HIGHsrc/integrations/prefect-gcp/prefect_gcp/decorators.py0validate include_files syntax at decoration time. checks: - all items are strings - no empty or whitespace-only strings STRING
HIGH…ns/prefect-kubernetes/prefect_kubernetes/decorators.py0validate include_files syntax at decoration time. checks: - all items are strings - no empty or whitespace-only strings STRING
HIGH…tegrations/prefect-docker/prefect_docker/decorators.py0validate include_files syntax at decoration time. checks: - all items are strings - no empty or whitespace-only strings STRING
HIGHsrc/integrations/prefect-aws/prefect_aws/decorators.py0validate include_files syntax at decoration time. checks: - all items are strings - no empty or whitespace-only strings STRING
217 more matches not shown…
Unused Imports1276 hits · 1177 pts
SeverityFileLineSnippetContext
LOWhatch_build.py1CODE
LOWtools/write_build_info.py1CODE
LOWtests/conftest.py50CODE
LOWtests/conftest.py95CODE
LOWtests/conftest.py96CODE
LOWtests/conftest.py98CODE
LOWtests/conftest.py99CODE
LOWtests/conftest.py100CODE
LOWtests/conftest.py101CODE
LOWtests/conftest.py102CODE
LOWtests/conftest.py103CODE
LOWtests/conftest.py104CODE
LOWtests/conftest.py105CODE
LOWtests/conftest.py106CODE
LOWtests/conftest.py107CODE
LOWtests/conftest.py108CODE
LOWtests/test_infrastructure_bound_flow.py1CODE
LOWtests/test_logging.py1CODE
LOWtests/test_logging.py89CODE
LOWtests/test_logging.py89CODE
LOWtests/test_logging.py90CODE
LOWtests/test_filesystems.py808CODE
LOWtests/test_versioning.py1CODE
LOWtests/test_transactions.py1CODE
LOWtests/test_flows_compat.py1CODE
LOWtests/test_ui_build_validation.py1CODE
LOWtests/test_background_tasks.py26CODE
LOWtests/test_types.py1CODE
LOWtests/test_settings.py1CODE
LOWtests/blocks/conftest.py8CODE
LOWtests/_internal/test_control_listener.py3CODE
LOWtests/docker/test_docker_image.py1CODE
LOWtests/docker/test_buildx.py3CODE
LOWtests/_experimental/bundles/test_zip_extractor.py8CODE
LOWtests/_experimental/bundles/test_zip_builder.py8CODE
LOW…experimental/bundles/test_include_files_integration.py8CODE
LOW…ts/_experimental/bundles/test_dependency_validation.py3CODE
LOWtests/_experimental/bundles/test_ignore_filter.py16CODE
LOWtests/_experimental/bundles/test_execute.py1CODE
LOWtests/_experimental/bundles/test_file_collector.py12CODE
LOWtests/_experimental/bundles/test_path_resolver.py9CODE
LOWtests/plugins/test_plugins.py5CODE
LOWtests/plugins/test_compat.py10CODE
LOWtests/runner/test__scheduled_run_poller.py1CODE
LOWtests/runner/test__deployment_registry.py1CODE
LOWtests/runner/test__workspace_resolver.py1CODE
LOWtests/runner/test__starter_bundle.py1CODE
LOWtests/runner/test__workspace_starter.py1CODE
LOWtests/runner/test__flow_run_executor.py1CODE
LOWtests/runner/test__cancellation_manager.py1CODE
LOWtests/runner/test__process_manager.py1CODE
LOWtests/runner/test__state_proposer.py1CODE
LOWtests/runner/test_runner.py1CODE
LOWtests/runner/test__control_channel.py3CODE
LOWtests/runner/test_control_channel_e2e.py19CODE
LOWtests/runner/test__starter_engine.py1CODE
LOWtests/runner/test__event_emitter.py1CODE
LOWtests/runner/test__flow_resolver.py1CODE
LOWtests/runner/test__hook_runner.py1CODE
LOWtests/runner/test__starter_direct.py1CODE
1216 more matches not shown…
Self-Referential Comments333 hits · 1062 pts
SeverityFileLineSnippetContext
MEDIUMtests/conftest.py387 # Create the storage path now, fixing an obscure bug where it can be created byCOMMENT
MEDIUMtests/conftest.py457 # Create an empty temporary database for use in the testsCOMMENT
MEDIUMtests/test_infrastructure_bound_flow.py913 # Create an initial flow run using the client directlyCOMMENT
MEDIUMtests/test_infrastructure_bound_flow.py961 # Create an initial flow run using the client directlyCOMMENT
MEDIUMtests/test_filesystems.py314 # Create a real fileCOMMENT
MEDIUMtests/test_filesystems.py318 # Create a symlink within the source directoryCOMMENT
MEDIUMtests/test_filesystems.py322 # Create a destination directoryCOMMENT
MEDIUMtests/test_filesystems.py345 # Create a real fileCOMMENT
MEDIUMtests/test_filesystems.py349 # Create a symlink within the source directoryCOMMENT
MEDIUMtests/test_filesystems.py353 # Create a destination directoryCOMMENT
MEDIUMtests/test_futures.py89 # Create a slow future first, then fast onesCOMMENT
MEDIUMtests/test_futures.py661 # Create a new future instance (simulating getting the future from delay())COMMENT
MEDIUMtests/test_artifacts.py998 # Create an artifact firstCOMMENT
MEDIUMtests/test_artifacts.py1017 # Create an artifact firstCOMMENT
MEDIUMtests/test_transactions.py723 # Create a result store with explicit NullFileSystem for metadata_storageCOMMENT
MEDIUMtests/test_transactions.py825 # Create a result store with explicit NullFileSystem for metadata_storageCOMMENT
MEDIUMtests/test_cache_policies.py222 # Create a compound policy with multiple Inputs policiesCOMMENT
MEDIUMtests/test_flow_engine.py5308 # Create a flow run with a deploymentCOMMENT
MEDIUMtests/test_context.py438 # Create a deployment and avoid red squigglesCOMMENT
MEDIUMtests/test_context.py448 # Create a flow run from the deploymentCOMMENT
MEDIUMtests/test_context.py453 # Define a wrapper function to ensure environment variables and settings propagate becauseCOMMENT
MEDIUMtests/test_context.py465 # Create a new settings object to pick up the new environment variablesCOMMENT
MEDIUMtests/test_settings.py2871 # Create a new settings instance to pick up the env varCOMMENT
MEDIUMtests/test_settings.py2992 # Create a new settings instance that will load from the profiles fileSTRING
MEDIUMtests/_internal/concurrency/test_services.py342 # Creating an instance from an async context is not always safe when sending anCOMMENT
MEDIUMtests/_internal/pydantic/test_validated_func.py428 # Define a test module namespace that simulates using future annotationsCOMMENT
MEDIUMtests/_internal/pydantic/test_validated_func.py431 # Create a model in that namespaceCOMMENT
MEDIUMtests/_internal/pydantic/test_validated_func.py445 # Define a function with the model as a parameter using string annotationCOMMENT
MEDIUMtests/_internal/pydantic/test_validated_func.py456 # Create an instance of the modelCOMMENT
MEDIUMtests/_internal/analytics/conftest.py80 # Create a fresh Prefect home in tmp_pathCOMMENT
MEDIUMtests/_experimental/bundles/test_zip_extractor.py765 # Create a valid zipCOMMENT
MEDIUMtests/_experimental/bundles/test_bundles.py102 # Create a mock flow runCOMMENT
MEDIUMtests/_experimental/bundles/test_bundles.py291 # Create a flow with include_filesCOMMENT
MEDIUMtests/_experimental/bundles/test_zip_builder.py387 # Create a file that will produce a zip >= 50MBCOMMENT
MEDIUM…experimental/bundles/test_include_files_integration.py421 # Create a sidecar zipCOMMENT
MEDIUM…experimental/bundles/test_include_files_integration.py444 # Create a helper script that copies files preserving directory structureCOMMENT
MEDIUM…experimental/bundles/test_include_files_integration.py690 # Create a real flow fileSTRING
MEDIUM…experimental/bundles/test_include_files_integration.py720 # Create a flow and set include_files (as @ecs decorator would)STRING
MEDIUMtests/_experimental/bundles/test_file_collector.py1137 # Create a file slightly over thresholdCOMMENT
MEDIUMtests/_experimental/bundles/test_path_resolver.py715 # Create a test fileCOMMENT
MEDIUMtests/_experimental/bundles/test_path_resolver.py729 # Create a file outside the base directoryCOMMENT
MEDIUMtests/_experimental/bundles/test_path_resolver.py685 # Create a test fileCOMMENT
MEDIUMtests/_experimental/bundles/test_path_resolver.py809 # Create a subdirectoryCOMMENT
MEDIUMtests/_experimental/bundles/test_path_resolver.py822 # Create a dotfileCOMMENT
MEDIUMtests/_experimental/bundles/test_path_resolver.py895 # Create the parent structure to ensure file existsCOMMENT
MEDIUMtests/input/test_run_input.py757 # Create a model with initial dataCOMMENT
MEDIUMtests/plugins/test_plugins.py272 # Create a mock module with a function-based pluginCOMMENT
MEDIUMtests/plugins/test_plugins.py296 # Create a mock module with an async function-based pluginCOMMENT
MEDIUMtests/runner/test_runner.py1195 # Create a mock flow runCOMMENT
MEDIUMtests/runner/test_runner.py2760 # Create an instance and add its flow methodCOMMENT
MEDIUMtests/runner/test_runner.py2787 # Create an instance and add its flow method with cancellation hookCOMMENT
MEDIUMtests/runner/test_runner.py2831 # Create an instance and add its flow method with crashed hookCOMMENT
MEDIUMtests/locking/test_filelock.py74 # Create a stale lock with a dead PIDCOMMENT
MEDIUMtests/locking/test_filelock.py167 # Create a lock held by "this process" so it won't be detectedCOMMENT
MEDIUMtests/server/models/test_flow_runs.py310 # Create a flow run with no labelsCOMMENT
MEDIUMtests/server/models/test_flow_runs.py269 # Create a flow run with initial labelsCOMMENT
MEDIUMtests/server/models/test_csrf_token.py46 # Create a tokenCOMMENT
MEDIUMtests/server/models/test_deployments.py272 # Create a global concurrency limit firstCOMMENT
MEDIUMtests/server/models/test_deployments.py1114 # Create a deployment with custom labelsCOMMENT
MEDIUMtests/server/models/test_deployments.py1159 # Create a deployment with custom labels and schedulesCOMMENT
273 more matches not shown…
Excessive Try-Catch Wrapping544 hits · 547 pts
SeverityFileLineSnippetContext
LOWtests/test_logging.py1778 except Exception:CODE
LOWtests/test_logging.py1855 except Exception as exc: # noqaCODE
LOWtests/test_flows.py2140 except Exception:CODE
LOWtests/test_exceptions.py55 except Exception as exc:CODE
LOWtests/test_exceptions.py65 except Exception as exc:CODE
MEDIUMtests/test_exceptions.py52def test_pickle_roundtrip_single_error(self):CODE
MEDIUMtests/test_exceptions.py62def test_pickle_roundtrip_two_errors(self):CODE
MEDIUMtests/test_tasks.py1429def test_flow():CODE
LOWtests/test_tasks.py3936 except Exception:CODE
LOWtests/test_tasks.py5498 except Exception:CODE
LOWtests/_internal/test_control_listener.py46 except Exception:CODE
LOWtests/_internal/test_control_listener.py66 except Exception:CODE
LOWtests/_internal/compatibility/test_migration.py57 except Exception as exc:CODE
LOWtests/utilities/test_importtools.py471 except Exception as e:STRING
LOWtests/utilities/test_pydantic.py41except Exception as exc:CODE
LOWtests/utilities/test_dockerutils.py17except Exception:CODE
LOWtests/utilities/test_urls.py484 except Exception:CODE
LOWtests/events/client/test_events_client.py445 except Exception as e:CODE
LOWintegration-tests/test_task_worker.py73 except Exception as e:CODE
LOWintegration-tests/test_flow_suspension.py64 except Exception as exc:CODE
LOWintegration-tests/test_flow_suspension.py209 except Exception:CODE
LOWintegration-tests/test_nested_cancellation.py99 except Exception as exc: # pragma: no cover - diagnostic pathCODE
LOWintegration-tests/test_client_context_lifespan.py112 except Exception as e:CODE
MEDIUMintegration-tests/test_client_context_lifespan.py113 print(f"Error entering client many times {e}")CODE
MEDIUMintegration-tests/test_client_context_lifespan.py35def lifespan(app):CODE
LOWintegration-tests/test_load_flows_concurrently.py37 except Exception as e:CODE
LOWintegration-tests/test_worker.py35 except Exception:CODE
LOWintegration-tests/test_schedule_statefulness.py49 except Exception as e:CODE
MEDIUMintegration-tests/test_schedule_statefulness.py50 print(f"Error checking schedules: {e}")CODE
LOWintegration-tests/test_runner_resilience.py76 except Exception as e:STRING
LOWintegration-tests/test_runner_resilience.py83 except Exception as e:STRING
LOWui-v2/e2e/helpers/run_flows.py172 except Exception as e:CODE
MEDIUMui-v2/e2e/helpers/run_flows.py173 print(f"Error running scenario '{args.scenario}': {e}", file=sys.stderr)CODE
LOWexamples/ai_database_cleanup_with_approval.py255 except Exception as e:CODE
LOWscripts/backfill_release_notes.py321 except Exception:CODE
LOWscripts/run-integration-flows.py47 except Exception as e:CODE
MEDIUMscripts/run-integration-flows.py48 print(f"Error running {script}: {e}")CODE
LOWscripts/all_links_should_be_ok.py38 except Exception:CODE
LOWscripts/all_links_should_be_ok.py48 except Exception as exc:CODE
LOWscripts/wait-for-server.py53 except Exception as exc:CODE
MEDIUMscripts/prepare_release_notes.py89 print(f"Error generating release notes: {e}")CODE
LOWscripts/prepare_release_notes.py339 except Exception:CODE
MEDIUMscripts/prepare_release_notes.py452 print(f"Error: Invalid version format '{version}'. Expected format: X.Y.Z")CODE
MEDIUMscripts/prepare_release_notes.py459 print(f"Error: Could not parse version '{version}'")CODE
MEDIUMscripts/prepare_integration_release_notes.py58 print(f"Error running command {' '.join(cmd)}: {e}", file=sys.stderr)CODE
LOWscripts/prepare_integration_release_notes.py122 except Exception:CODE
MEDIUMscripts/prepare_integration_release_notes.py354 print(f"Error: Package '{args.package}' not found.", file=sys.stderr)STRING
LOWscripts/test_unc_paths.py64 except Exception as e:STRING
MEDIUMscripts/test_unc_paths.py65 print(f"Error: {type(e).__name__}: {e}")STRING
LOWscripts/generate_mintlify_openapi_docs.py113 except Exception:CODE
MEDIUMscripts/generate_api_ref.py35 print(f"Error generating API reference: {result.stderr}", file=sys.stderr)CODE
LOW…integrations/prefect-dbt/prefect_dbt/core/_manifest.py619 except Exception:CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py743 except Exception as e:CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1286 except Exception as exc:CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1364 except Exception:CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1392 except Exception as exc:CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1578 except Exception:CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1593 except Exception as exc:CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1942 except Exception:CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1975 except Exception:CODE
484 more matches not shown…
Deep Nesting434 hits · 364 pts
SeverityFileLineSnippetContext
LOWtests/conftest.py571CODE
LOWtests/test_flows.py2086CODE
LOWtests/test_settings.py2652CODE
LOWtests/_internal/concurrency/test_cancellation.py364CODE
LOWtests/_internal/concurrency/test_cancellation.py395CODE
LOWtests/_internal/concurrency/test_cancellation.py416CODE
LOWtests/_internal/concurrency/test_cancellation.py456CODE
LOWtests/_internal/concurrency/test_cancellation.py500CODE
LOWtests/_internal/concurrency/test_cancellation.py539CODE
LOWtests/_internal/concurrency/test_cancellation.py561CODE
LOWtests/_internal/concurrency/test_cancellation.py566CODE
LOWtests/experimental/test_bundles.py854CODE
LOWtests/plugins/test_plugins.py479CODE
LOWtests/plugins/test_plugins.py562CODE
LOWtests/runner/test_control_channel_e2e.py63CODE
LOWtests/runner/test__starter_engine.py196CODE
LOWtests/runner/test__starter_engine.py399CODE
LOWtests/runner/test__starter_engine.py433CODE
LOWtests/server/models/test_filters.py51CODE
LOW…sts/server/orchestration/api/test_flow_run_graph_v2.py41CODE
LOWtests/server/orchestration/api/test_workers.py3958CODE
LOWtests/server/orchestration/api/ui/test_task_runs.py181CODE
LOWtests/cli/test_start_server.py49CODE
LOWtests/cli/test_deploy.py2763CODE
LOWtests/cli/test_deploy.py2797CODE
LOWtests/cli/test_transfer.py30CODE
LOWtests/concurrency/test_leases.py108CODE
LOWtests/workers/test_cleanup.py886CODE
LOWtests/events/server/triggers/test_flow_run_slas.py761CODE
LOW…/events/server/models/test_automation_notifications.py121CODE
LOW…s/events/server/actions/test_jinja_templated_action.py652CODE
LOW…s/events/server/actions/test_jinja_templated_action.py661CODE
LOWtests/infrastructure/provisioners/test_cloud_run.py241CODE
LOWtests/infrastructure/provisioners/test_cloud_run.py242CODE
LOWtests/infrastructure/provisioners/test_cloud_run_v2.py211CODE
LOWtests/infrastructure/provisioners/test_cloud_run_v2.py212CODE
LOWtests/infrastructure/provisioners/test_ecs.py971CODE
LOWtests/infrastructure/provisioners/test_ecs.py986CODE
LOWscripts/generate_settings_ref.py13CODE
LOWscripts/generate_settings_ref.py55CODE
LOWscripts/backfill_release_notes.py102CODE
LOWscripts/prepare_release_notes.py104CODE
LOWscripts/prepare_release_notes.py345CODE
LOWscripts/prepare_release_notes.py399CODE
LOWscripts/prepare_integration_release_notes.py167CODE
LOWscripts/prepare_integration_release_notes.py361CODE
LOWscripts/generate_cli_docs.py97CODE
LOWscripts/generate_example_pages.py70CODE
LOWscripts/verify_test_selection.py38CODE
LOWscripts/generate_mintlify_openapi_docs.py39CODE
LOWscripts/pyright_diff.py60CODE
LOW…integrations/prefect-dbt/prefect_dbt/core/_manifest.py361CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py795CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py880CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1013CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1095CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1345CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1596CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1711CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1807CODE
374 more matches not shown…
Hallucination Indicators31 hits · 315 pts
SeverityFileLineSnippetContext
CRITICALtests/cli/test_api_command.py165 assert route.calls.last.request.headers.get("X-Custom") == "value"CODE
CRITICALtests/cli/test_api_command.py190 assert route.calls.last.request.headers.get("X-Custom-1") == "value1"CODE
CRITICALtests/cli/test_api_command.py191 assert route.calls.last.request.headers.get("X-Custom-2") == "value2"CODE
CRITICALsrc/integrations/prefect-dbt/tests/cloud/test_jobs.py243 request_body = json.loads(respx_mock.calls.last.request.content.decode())CODE
CRITICALsrc/integrations/prefect-dbt/tests/cloud/test_jobs.py1623 request_body = json.loads(respx_mock.calls.last.request.content.decode())CODE
CRITICALsrc/integrations/prefect-dbt/tests/cloud/test_jobs.py1650 request_body = json.loads(respx_mock.calls.last.request.content.decode())CODE
CRITICAL…owflake/prefect_snowflake/experimental/workers/spcs.py23from snowflake.core.exceptions import NotFoundErrorCODE
CRITICAL…efect-snowflake/tests/experimental/test_spcs_worker.py1819 from snowflake.core.exceptions import NotFoundErrorCODE
CRITICAL…efect-snowflake/tests/experimental/test_spcs_worker.py534 from snowflake.core.exceptions import NotFoundErrorCODE
CRITICAL…efect-snowflake/tests/experimental/test_spcs_worker.py1188 from snowflake.core.exceptions import NotFoundErrorCODE
CRITICALsrc/integrations/prefect-docker/tests/test_images.py34 client.__enter__.return_value.images.pull.assert_called_once_with(CODE
CRITICALsrc/integrations/prefect-docker/tests/test_images.py56 client.__enter__.return_value.images.pull.assert_called_once_with(CODE
CRITICALsrc/integrations/prefect-docker/tests/test_images.py70 client.__enter__.return_value.images.pull.assert_called_once_with(**pull_kwargs)CODE
CRITICALsrc/integrations/prefect-docker/tests/test_worker.py1584 mock_docker_client.containers.get.return_value.stop.assert_called_once_with(CODE
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py32 client.__enter__.return_value.containers.create.assert_called_once_with(CODE
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py47 client.__enter__.return_value.containers.get.assert_called_once_with("42")CODE
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py60 client.__enter__.return_value.containers.get.assert_called_once_with("42")CODE
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py73 client.__enter__.return_value.containers.get.assert_called_once_with("42")CODE
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py86 client.__enter__.return_value.containers.get.assert_called_once_with("42")CODE
CRITICAL…rations/prefect-docker/tests/deployments/test_steps.py197 mock_docker_client.images.get.return_value.tag.assert_has_calls(CODE
CRITICAL…rations/prefect-docker/tests/deployments/test_steps.py206 mock_docker_client.images.get.return_value.tag.assert_called_once_with(CODE
CRITICAL…rations/prefect-docker/tests/deployments/test_steps.py654 mock_docker_client.images.get.return_value.tag.assert_called_once_with(CODE
CRITICAL…rations/prefect-docker/tests/deployments/test_steps.py676 mock_docker_client.images.get.return_value.tag.assert_called_once_with(CODE
CRITICALsrc/integrations/prefect-azure/tests/conftest.py4from azure.core.exceptions import ResourceExistsErrorCODE
CRITICALsrc/integrations/prefect-azure/tests/test_aci_worker.py12from azure.core.exceptions import HttpResponseError, ResourceNotFoundErrorCODE
CRITICAL…/integrations/prefect-azure/tests/test_blob_storage.py6from azure.core.exceptions import ResourceExistsErrorCODE
CRITICAL…efect-azure/tests/experimental/bundles/test_execute.py8from azure.core.exceptions import ResourceNotFoundErrorCODE
CRITICAL…refect-azure/tests/experimental/bundles/test_upload.py5from azure.core.exceptions import ResourceExistsErrorCODE
CRITICAL…tegrations/prefect-azure/prefect_azure/blob_storage.py8from azure.core.exceptions import ResourceNotFoundErrorCODE
CRITICAL…fect-azure/prefect_azure/workers/container_instance.py81from azure.core.exceptions import HttpResponseError, ResourceNotFoundErrorCODE
CRITICALsrc/prefect/tasks.py186 context.task.fn.__code__.co_code.hex(),CODE
Cross-Language Confusion63 hits · 255 pts
SeverityFileLineSnippetContext
HIGHtests/docker/test_docker_image.py71 image.push()CODE
HIGHtests/docker/test_docker_image.py88 image.push() # should not raiseCODE
HIGHtests/docker/test_docker_image.py217 image.push()CODE
HIGHtests/docker/test_docker_image.py233 image.push()CODE
HIGHtests/docker/test_docker_image.py197 image.push()CODE
HIGHtests/server/database/test_migrations.py815 "INSERT INTO flow_run_notification_policy (is_active, state_names, tags, message_template, block_docCODE
HIGHtests/server/orchestration/api/test_work_queues.py1617 when they entered the PENDING state, not start_time (which is null)."""STRING
HIGHtests/_sdk/test_schema_converter_unions.py7 """Test conversion of nullable (anyOf with null) types."""STRING
HIGHtests/_sdk/test_schema_converter_unions.py153 e.g., anyOf: [ {"type":"array","items":{"anyOf":[str, int]}}, null ]STRING
HIGHtests/deployment/test_steps.py1530 "echo first && echo second",STRING
HIGHsrc/integrations/prefect-github/prefect_github/user.py2356 privacy: If non-null, filters repositoriesSTRING
HIGHsrc/integrations/prefect-github/prefect_github/user.py2360 is_locked: If non-null, filters repositoriesSTRING
HIGHsrc/integrations/prefect-github/prefect_github/user.py2364 contribution_types: If non-null, includeSTRING
HIGHsrc/integrations/prefect-github/prefect_github/user.py532 privacy: If non-null, filters repositories according to privacy.STRING
HIGHsrc/integrations/prefect-github/prefect_github/user.py543 is_locked: If non-null, filters repositories according toSTRING
HIGHsrc/integrations/prefect-github/prefect_github/user.py1143 privacy: If non-null, filters repositories according toSTRING
HIGHsrc/integrations/prefect-github/prefect_github/user.py1155 is_locked: If non-null, filters repositories according toSTRING
HIGHsrc/integrations/prefect-github/prefect_github/user.py1163 is_fork: If non-null, filters repositories according toSTRING
HIGH…c/integrations/prefect-github/prefect_github/viewer.py2108 privacy: If non-null, filters repositoriesSTRING
HIGH…c/integrations/prefect-github/prefect_github/viewer.py2112 is_locked: If non-null, filters repositoriesSTRING
HIGH…c/integrations/prefect-github/prefect_github/viewer.py2116 contribution_types: If non-null, includeSTRING
HIGH…c/integrations/prefect-github/prefect_github/viewer.py476 privacy: If non-null, filters repositories according to privacy.STRING
HIGH…c/integrations/prefect-github/prefect_github/viewer.py487 is_locked: If non-null, filters repositories according toSTRING
HIGH…c/integrations/prefect-github/prefect_github/viewer.py1021 privacy: If non-null, filters repositories according toSTRING
HIGH…c/integrations/prefect-github/prefect_github/viewer.py1033 is_locked: If non-null, filters repositories according toSTRING
HIGH…c/integrations/prefect-github/prefect_github/viewer.py1041 is_fork: If non-null, filters repositories according toSTRING
HIGH…grations/prefect-github/prefect_github/organization.py128 privacy: If non-null, filters teams according to privacy.STRING
HIGH…grations/prefect-github/prefect_github/organization.py129 role: If non-null, filters teams according to whether the viewerSTRING
HIGH…grations/prefect-github/prefect_github/organization.py131 query: If non-null, filters teams with query on team name and teamSTRING
HIGH…grations/prefect-github/prefect_github/organization.py944 privacy: If non-null, filters repositories according toSTRING
HIGH…grations/prefect-github/prefect_github/organization.py956 is_locked: If non-null, filters repositories according toSTRING
HIGH…grations/prefect-github/prefect_github/organization.py964 is_fork: If non-null, filters repositories according toSTRING
HIGH…tegrations/prefect-github/prefect_github/repository.py439 privacy: If non-null, filters repositories according to privacy.STRING
HIGH…tegrations/prefect-github/prefect_github/repository.py450 is_locked: If non-null, filters repositories according to whetherSTRING
HIGH…ions/prefect-github/prefect_github/repository_owner.py133 privacy: If non-null, filters repositories according toSTRING
HIGH…ions/prefect-github/prefect_github/repository_owner.py145 is_locked: If non-null, filters repositories according toSTRING
HIGH…ions/prefect-github/prefect_github/repository_owner.py153 is_fork: If non-null, filters repositories according toSTRING
HIGH…c/integrations/prefect-dask/tests/test_task_runners.py392 assert result.equals(pd.Series([3, 6], index=["x", "y"]))CODE
HIGH…ons/prefect-docker/prefect_docker/deployments/steps.py532 client.api.push(CODE
HIGH…ons/prefect-docker/prefect_docker/deployments/steps.py538 client.api.push(CODE
HIGH…grations/prefect-aws/prefect_aws/workers/ecs_worker.py325 "the task when it is launching. If this value is not null, it will "STRING
HIGH…grations/prefect-aws/prefect_aws/workers/ecs_worker.py546 "not null, it will override the value in the task definition. This value "STRING
HIGH…grations/prefect-aws/prefect_aws/workers/ecs_worker.py607 "the task when it is launching. If this value is not null, it will "STRING
HIGH…grations/prefect-aws/prefect_aws/workers/ecs_worker.py619 "If using the 'awsvpc' network mode and this field is null, your default "STRING
HIGH…tions/prefect-aws/prefect_aws/observers/diagnostics.py70 # --- Container exit code analysis (non-zero or null) -------------------COMMENT
HIGHsrc/integrations/prefect-shell/tests/test_commands.py127 command="echo $HOME && echo $TEST_VAR",CODE
HIGHsrc/prefect/serializers.py298 level: If not null, the level of compression to pass to `compress`.STRING
HIGHsrc/prefect/states.py463 If the state result is null, a wrapper exception will be returned with the stateSTRING
HIGHsrc/prefect/states.py549 If the state result is null, a wrapper exception will be returned with the stateSTRING
HIGHsrc/prefect/_internal/buildx.py211 python_on_whales.docker.image.push(full_name)CODE
HIGHsrc/prefect/docker/docker_image.py162 events = client.api.push(CODE
HIGHsrc/prefect/server/database/query_components.py235 # if null, no limit will be appliedCOMMENT
HIGH…04_09_125712_cc510aec4689_automation_event_follower.py48 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n CODE
HIGH…4_03_13_111316_bacc60edce16_create_csrf_token_toble.py35 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n CODE
HIGH…e/2024_04_03_111618_07ed05dfd4ec_automations_models.py58 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n CODE
HIGH…e/2024_04_03_111618_07ed05dfd4ec_automations_models.py120 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n CODE
HIGH…e/2024_04_03_111618_07ed05dfd4ec_automations_models.py175 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n CODE
HIGH…e/2024_04_03_111618_07ed05dfd4ec_automations_models.py246 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n CODE
HIGH…e/2024_04_10_104304_824e9edafa60_adds_events_tables.py37 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n CODE
HIGH…e/2024_04_10_104304_824e9edafa60_adds_events_tables.py111 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n CODE
3 more matches not shown…
Redundant / Tautological Comments129 hits · 190 pts
SeverityFileLineSnippetContext
LOWtests/conftest.py337 # Set PREFECT_HOME to a temporary directory to avoid clobberingCOMMENT
LOWtests/test_flow_engine.py5043 # Set heartbeat_frequency to enable heartbeatsCOMMENT
LOWtests/test_flow_engine.py5108 # Set heartbeat_frequency to None (disabled)COMMENT
LOWtests/test_flow_engine.py5136 # Set heartbeat_frequency to None (disabled)COMMENT
LOWtests/server/orchestration/api/test_bulk_operations.py392 # Set state to cancelledCOMMENT
LOWtests/server/orchestration/api/test_flow_runs.py355 # Set limit to 50 bytes; even a small payload should failCOMMENT
LOWtests/server/orchestration/api/test_deployments.py3825 # Set work_queue to None by removing the work_queue relationshipCOMMENT
LOWtests/server/services/test_foreman.py474 # Set inactivity_heartbeat_multiple to 0 to immediately mark worker as offlineCOMMENT
LOWtests/cli/test_deploy.py3734 # Check if the deployment was created correctlyCOMMENT
LOWtests/cli/test_deploy.py3744 # Check if the second deployment was not createdCOMMENT
LOWtests/cli/test_deploy.py3499 # Check if deployments were created correctlyCOMMENT
LOWtests/cli/test_deploy.py3676 # Check if the two deployments were created correctlyCOMMENT
LOWtests/cli/test_deploy.py3691 # Check if the third deployment was not createdCOMMENT
LOWtests/cli/test_deploy.py3797 # Check if deployments were created correctly and without the provided CLI optionsCOMMENT
LOWtests/cli/test_deploy.py4069 # Check if the deployment was created correctlyCOMMENT
LOWtests/cli/test_deploy.py4169 # Check if the deployment was created correctlyCOMMENT
LOWtests/cli/test_deploy.py4230 # Check if the deployment was created correctlyCOMMENT
LOWtests/cli/test_deploy.py4310 # Check if the deployment was created correctlyCOMMENT
LOWtests/cli/test_deploy.py4401 # Check if the deployments were not createdCOMMENT
LOWtests/cli/test_deploy.py4478 # Check if the deployment was created correctlyCOMMENT
LOWtests/cli/test_deploy.py4605 # Check if the deployment was created correctlyCOMMENT
LOWtests/cli/test_deploy.py4742 # Check if the deployment was created correctlyCOMMENT
LOWtests/cli/test_deploy.py4789 # Check if the deployments were created correctlyCOMMENT
LOWtests/cli/test_deploy.py6674 # Check if deployments were created correctlyCOMMENT
LOWtests/utilities/test_hashing.py59 # Check if the hash is stableCOMMENT
LOW…/events/server/models/test_automation_notifications.py59 # Check if we're using PostgreSQLCOMMENT
LOW…infrastructure/provisioners/test_container_instance.py1326 None, # Assign identity to registryCODE
LOW…infrastructure/provisioners/test_container_instance.py1634 None, # Assign identity to registryCODE
LOW…infrastructure/provisioners/test_container_instance.py1973 None, # Assign identity to registryCODE
LOW…infrastructure/provisioners/test_container_instance.py2322 None, # Assign identity to registryCODE
LOWtests/infrastructure/provisioners/test_modal.py104 # Check if the block document exists and has expected valuesCOMMENT
LOWtests/infrastructure/provisioners/test_modal.py112 # Check if the base job template was updatedCOMMENT
LOWtests/infrastructure/provisioners/test_modal.py149 # Check if the base job template was updatedCOMMENT
LOWtests/infrastructure/provisioners/test_modal.py190 # Check if the block document exists and has expected valuesCOMMENT
LOWtests/infrastructure/provisioners/test_modal.py198 # Check if the base job template was updatedCOMMENT
LOWtests/infrastructure/provisioners/test_coiled.py101 # Check if the block document exists and has expected valuesCOMMENT
LOWtests/infrastructure/provisioners/test_coiled.py108 # Check if the base job template was updatedCOMMENT
LOWtests/infrastructure/provisioners/test_coiled.py131 # Check if the base job template was updatedCOMMENT
LOWtests/infrastructure/provisioners/test_coiled.py170 # Check if the block document exists and has expected valuesCOMMENT
LOWtests/infrastructure/provisioners/test_coiled.py177 # Check if the base job template was updatedCOMMENT
LOWtests/infrastructure/provisioners/test_ecs.py85 # Check if provisioning is neededCOMMENT
LOWtests/infrastructure/provisioners/test_ecs.py224 # Check if the IAM user existsCOMMENT
LOWtests/infrastructure/provisioners/test_ecs.py119 # Check if the IAM policy existsCOMMENT
LOWtests/infrastructure/provisioners/test_ecs.py330 # Check if the block document existsCOMMENT
LOWload_testing/run-server.sh13 # Check if container existsCOMMENT
LOWexamples/ai_data_analyst_with_pydantic_ai.py264 # Display resultsCOMMENT
LOWexamples/ai_data_analyst_with_pydantic_ai.py279 # Check if OpenAI API key is setCOMMENT
LOWscripts/backfill_release_notes.py223 # Check if we need to add spacingCOMMENT
LOWscripts/backfill_release_notes.py235 # Check if we need to add spacingCOMMENT
LOWscripts/prepare_release_notes.py231 # Check if we need to add spacingCOMMENT
LOWscripts/prepare_release_notes.py243 # Check if we need to add spacingCOMMENT
LOWscripts/prepare_integration_release_notes.py396 # Check if file exists to determine if we need frontmatterCOMMENT
LOWclient/client_deploy.py21 # Check if the smoke-test work pool existsCOMMENT
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py868 # Check if any of the test's parents is node_idCOMMENT
LOWsrc/integrations/prefect-dbt/prefect_dbt/core/runner.py912 # Check if event has a message (cheap attribute access)COMMENT
LOWsrc/integrations/prefect-dbt/prefect_dbt/core/runner.py1247 # Check if this is a valid dbt commandCOMMENT
LOW…t_kubernetes_integration_tests/test_crash_detection.py78 # Check if we got at least the pending event - but only if we have eventsCOMMENT
LOW…ions/prefect-kubernetes/prefect_kubernetes/observer.py193 # Check if a corresponding event already exists. If so, we don't need to emit a new one.COMMENT
LOW…ions/prefect-kubernetes/prefect_kubernetes/observer.py707 # Check if there are any other jobs with this flow run labelCOMMENT
LOW…ions/prefect-kubernetes/prefect_kubernetes/observer.py715 # Check if any other job is completed or runningCOMMENT
69 more matches not shown…
Modern AI Meta-Vocabulary58 hits · 175 pts
SeverityFileLineSnippetContext
MEDIUMplans/2026-01-12-deployment-crud-events.md28# Cloud uses prefect.* prefix for orchestration objectsCOMMENT
MEDIUMtests/test_background_tasks.py210 # after orchestration in a way that differs by microseconds, or theCOMMENT
MEDIUMtests/server/models/test_flow_run_states.py118 # Do not start until we are orchestrating in session 1COMMENT
MEDIUMtests/server/models/test_flow_run_states.py270 # put the run in a pending state, which succeeds due to injected orchestrationCOMMENT
MEDIUMtests/server/models/test_task_run_states.py187 # put the run in a pending state, which succeeds due to injected orchestrationCOMMENT
MEDIUM…ion/test_validate_deployment_concurrency_at_running.py491 # Set up two orchestration contextsCOMMENT
MEDIUM…rchestration/test_flow_run_instrumentation_policies.py181 # send the pending state through orchestration so it is written to the DBCOMMENT
MEDIUM…rchestration/test_flow_run_instrumentation_policies.py239 # send the pending state through orchestration so it is written to the DBCOMMENT
MEDIUMtests/server/orchestration/test_core_policy.py2334 # from being accepted, but this orchestration rule is the wrong place to do itCOMMENT
MEDIUMtests/server/orchestration/test_core_policy.py4855 # The orchestration rule should handle the error gracefullyCOMMENT
MEDIUM…/orchestration/test_task_concurrency_v2_integration.py466 # Set validated state to completed (normally done by orchestration)COMMENT
MEDIUM…/orchestration/test_task_concurrency_v2_integration.py565 # Set validated state to completed (normally done by orchestration)COMMENT
MEDIUM…/orchestration/test_task_concurrency_v2_integration.py715 # Set validated state to completed (normally done by orchestration)COMMENT
MEDIUMtests/server/orchestration/api/test_flow_runs.py1910 # A multi-agent environment may attempt to orchestrate a run more than once,COMMENT
MEDIUMtests/server/orchestration/api/test_flow_runs.py1910 # A multi-agent environment may attempt to orchestrate a run more than once,COMMENT
MEDIUMtests/client/test_prefect_client.py175 assert pool._retries == 3 # set in prefect.client.orchestration.get_client()CODE
MEDIUMtests/client/test_prefect_client.py215 assert pool._retries == 3 # set in prefect.client.orchestration.get_client()CODE
MEDIUMtests/client/test_prefect_client.py247 assert pool._retries == 3 # set in prefect.client.orchestration.get_client()CODE
MEDIUMexamples/hello_world.py12# 1. Ship production-ready orchestration code with **zero boilerplate**.COMMENT
MEDIUMexamples/hello_world.py76# This simple example demonstrates Prefect's core value proposition: taking regular Python code and enhancing it with prCOMMENT
MEDIUMexamples/hello_world.py96# Prefect lets you orchestrate these operations effortlessly with automatic observability, error handling, and retries.COMMENT
MEDIUMexamples/hello_world.py108# The `@flow` decorator is your gateway to enterprise-grade orchestration - no complex configuration needed!COMMENT
MEDIUMexamples/hello_world.py111# For more information about the orchestration concepts demonstrated in this example, see the [Prefect documentation](htCOMMENT
MEDIUMexamples/ai_data_analyst_with_pydantic_ai.py344# For more on AI orchestration with Prefect:COMMENT
MEDIUMexamples/run_api_sourced_etl.py17# * **Prefect** wraps the whole thing in battle-tested orchestration: automatic [retries](https://docs.prefect.io/v3/devCOMMENT
MEDIUMexamples/run_api_sourced_etl.py42# Watch as Prefect orchestrates the ETL pipeline with automatic retries and logging. The flow fetches multiple pages of COMMENT
MEDIUMexamples/run_api_sourced_etl.py121# Flow – orchestrate the ETL with optional concurrencyCOMMENT
MEDIUMexamples/run_api_sourced_etl.py171# Prefect lets you focus on *data*, not orchestration plumbing – happy ETL-ing! 🎉COMMENT
MEDIUMexamples/run_dbt_with_prefect.py17# * **Prefect** wraps the entire workflow in battle-tested orchestration: automatic [retries](https://docs.prefect.io/v3COMMENT
MEDIUMexamples/run_dbt_with_prefect.py37# Write three focused Python functions (download project, run dbt commands, orchestrate workflow), add Prefect decoratorCOMMENT
MEDIUMexamples/run_dbt_with_prefect.py45# Watch as Prefect orchestrates the complete dbt lifecycle: downloading the project, running models, executing tests, anCOMMENT
MEDIUMexamples/run_dbt_with_prefect.py222# This flow orchestrates the standard dbt workflow: deps → seed → run → test.COMMENT
MEDIUMexamples/run_dbt_with_prefect.py276# Traditional dbt orchestration often involves brittle shell scripts, complex YAML configurations, or heavyweight workflCOMMENT
MEDIUMexamples/run_dbt_with_prefect.py287# To learn more about orchestrating analytics workflows with Prefect, check out:COMMENT
MEDIUMexamples/atproto_dashboard_with_prefect_assets.py25# * **Flow orchestration** – Coordinate asset materialization with retries and schedulingCOMMENT
MEDIUMexamples/simple_web_scraper.py88# `@flow` elevates a function to a *flow* – the orchestration nucleus that can callCOMMENT
MEDIUMexamples/simple_web_scraper.py135# Happy scraping – and happy orchestrating! 🎉COMMENT
MEDIUMbenches/bench_tasks.py31 # measuring any other part of orchestration / collection of resultsCOMMENT
MEDIUM…tions/prefect-aws/tests/observers/test_ecs_observer.py2475 # Can't identify which container is the orchestration oneCOMMENT
MEDIUM…tions/prefect-aws/tests/observers/test_ecs_observer.py2501 # Custom orchestration container exits 0, sidecar exits 1.COMMENT
MEDIUM…grations/prefect-aws/prefect_aws/workers/ecs_worker.py406 # the name to treat as the "orchestration" container.STRING
MEDIUM…/integrations/prefect-aws/prefect_aws/observers/ecs.py877 # Run diagnosis when the orchestration container failed or when thereCOMMENT
MEDIUM…/integrations/prefect-aws/prefect_aws/observers/ecs.py979 # unambiguously the orchestration container (customCOMMENT
MEDIUM…/integrations/prefect-aws/prefect_aws/observers/ecs.py984 # name — can't distinguish orchestration from sidecars.COMMENT
MEDIUMsrc/prefect/context.py474 # In-process suspension request used to stop execution at orchestrationCOMMENT
MEDIUMsrc/prefect/flow_engine.py679 # if orchestrating a run already in a pending state, force orchestration toCOMMENT
MEDIUMsrc/prefect/flow_engine.py1380 # if orchestrating a run already in a pending state, force orchestration toCOMMENT
MEDIUMsrc/prefect/task_engine.py941 # if orchestrating a run already in a pending state, force orchestration toCOMMENT
MEDIUMsrc/prefect/task_engine.py1137 # if orchestrating a run already in a pending state, force orchestration toCOMMENT
MEDIUMsrc/prefect/task_engine.py1572 # if orchestrating a run already in a pending state, force orchestration toCOMMENT
MEDIUMsrc/prefect/task_runners.py633 # and its associated orchestration client for tasks that neverCOMMENT
MEDIUMsrc/prefect/runner/_starter_engine.py143 # That responsibility stays with the Runner orchestration layer (or aCOMMENT
MEDIUMsrc/prefect/server/models/task_runs.py544 # apply orchestration rules and create the new task run stateCOMMENT
MEDIUMsrc/prefect/server/models/flow_runs.py623 # Lock the row to prevent orchestration race conditionsCOMMENT
MEDIUMsrc/prefect/server/models/flow_runs.py652 # apply orchestration rules and create the new flow run stateCOMMENT
MEDIUMsrc/prefect/server/orchestration/core_policy.py1759 # orchestration rules on the initial PENDING state.COMMENT
MEDIUMsrc/prefect/server/api/flow_runs.py130 # pass the request version to the orchestration engine to support compatibility codeCOMMENT
MEDIUMsrc/prefect/server/api/flow_runs.py845 # pass the request version to the orchestration engine to support compatibility codeCOMMENT
AI Structural Patterns221 hits · 173 pts
SeverityFileLineSnippetContext
LOWtests/test_assets.py1764CODE
LOWtests/test_tasks.py2233CODE
LOWtests/test_tasks.py5723CODE
LOWtests/test_tasks.py5740CODE
LOWtests/test_variables.py257CODE
LOWtests/input/test_actions.py296CODE
LOWtests/input/test_actions.py312CODE
LOWtests/runtime/test_deployment.py19CODE
LOWtests/runtime/test_deployment.py245CODE
LOWtests/runtime/test_deployment.py251CODE
LOWtests/results/test_flow_results.py540CODE
LOWtests/engine/reliability/test_deadlocks.py20CODE
LOWexamples/per_worker_task_concurrency.py120CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py597CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py880CODE
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1807CODE
LOWsrc/integrations/prefect-dbt/prefect_dbt/core/runner.py148CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py103CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py156CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py451CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py477CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py535CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py561CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py619CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py645CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py703CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py729CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py787CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py813CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py871CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/commands.py897CODE
LOWsrc/integrations/prefect-dbt/tests/core/conftest.py15CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py44CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py72CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py200CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1146CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1270CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1392CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/utilities.py200CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/utilities.py207CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/utilities.py214CODE
LOW…rations/prefect-gcp/prefect_gcp/models/cloud_run_v2.py169CODE
LOW…rations/prefect-gcp/prefect_gcp/models/cloud_run_v2.py222CODE
LOW…rations/prefect-gcp/prefect_gcp/models/cloud_run_v2.py248CODE
LOW…ions/prefect-gcp/tests/test_bigquery_async_dispatch.py70CODE
LOW…ions/prefect-gcp/tests/test_bigquery_async_dispatch.py113CODE
LOW…ions/prefect-gcp/tests/test_bigquery_async_dispatch.py156CODE
LOW…ions/prefect-gcp/tests/test_bigquery_async_dispatch.py201CODE
LOW…ions/prefect-gcp/tests/test_bigquery_async_dispatch.py250CODE
LOWsrc/integrations/prefect-gcp/tests/test_bigquery.py113CODE
LOWsrc/integrations/prefect-gcp/tests/test_bigquery.py129CODE
LOWsrc/integrations/prefect-gcp/tests/test_bigquery.py150CODE
LOW…prefect-gcp/tests/test_cloud_storage_async_dispatch.py56CODE
LOW…prefect-gcp/tests/test_cloud_storage_async_dispatch.py95CODE
LOW…prefect-gcp/tests/test_cloud_storage_async_dispatch.py136CODE
LOW…prefect-gcp/tests/test_cloud_storage_async_dispatch.py175CODE
LOW…prefect-gcp/tests/test_cloud_storage_async_dispatch.py218CODE
LOW…refect-gcp/tests/test_secret_manager_async_dispatch.py54CODE
LOW…refect-gcp/tests/test_secret_manager_async_dispatch.py92CODE
LOW…refect-gcp/tests/test_secret_manager_async_dispatch.py125CODE
161 more matches not shown…
Modern Structural Boilerplate146 hits · 150 pts
SeverityFileLineSnippetContext
LOWtests/test_logging.py1013 def set_client(self, client: PrefectClient) -> None:STRING
LOWtests/workers/test_base_worker.py3269 async def update_work_pool(*args: Any, **kwargs: Any) -> None:CODE
LOWintegration-tests/test_setup_logging.py10logger = logging.getLogger(__name__)CODE
LOWscripts/generate_example_pages.py180async def update_docs_json(examples: list[Example]) -> None:STRING
LOWsrc/integrations/prefect-dbt/prefect_dbt/__init__.py19__all__ = [CODE
LOW…integrations/prefect-dbt/prefect_dbt/core/_manifest.py26logger = logging.getLogger(__name__)CODE
LOW…/integrations/prefect-dbt/prefect_dbt/core/__init__.py5__all__ = ["DbtHookContext", "PrefectDbtRunner", "PrefectDbtSettings"]CODE
LOW…/integrations/prefect-dbt/prefect_dbt/core/_tracker.py103 def set_task_result(self, node_id: str, result: Any) -> None:CODE
LOW…/integrations/prefect-dbt/prefect_dbt/core/_tracker.py111 def set_node_dependencies(self, node_id: str, dependencies: list[str]) -> None:CODE
LOW…/integrations/prefect-dbt/prefect_dbt/core/_tracker.py119 def set_task_run_id(self, node_id: str, task_run_id: UUID) -> None:CODE
LOW…/integrations/prefect-dbt/prefect_dbt/core/_tracker.py127 def set_task_run_name(self, node_id: str, task_run_name: str) -> None:CODE
LOW…c/integrations/prefect-dbt/prefect_dbt/cli/__init__.py35__all__ = [CODE
LOWsrc/integrations/prefect-gcp/prefect_gcp/decorators.py27__all__ = ["cloud_run", "vertex_ai"]CODE
LOW…tions/prefect-gcp/prefect_gcp/experimental/__init__.py12__all__ = ["cloud_run", "vertex_ai"]CODE
LOW…ons/prefect-gcp/prefect_gcp/experimental/decorators.py13__all__ = ["cloud_run", "vertex_ai"]CODE
LOW…prefect-gcp/prefect_gcp/experimental/bundles/upload.py17__all__ = ["UploadBundleToGcsOutput", "main", "upload_bundle_to_gcs"]CODE
LOW…refect-gcp/prefect_gcp/experimental/bundles/execute.py13__all__ = ["execute_bundle_from_gcs", "main"]CODE
LOW…efect-gcp/prefect_gcp/experimental/bundles/__init__.py17__all__ = ["upload_bundle_to_gcs", "execute_bundle_from_gcs"]CODE
LOW…c/integrations/prefect-email/prefect_email/__init__.py7__all__ = ["EmailServerCredentials", "SMTPServer", "SMTPType", "email_send_message"]CODE
LOW…ns/prefect-kubernetes/prefect_kubernetes/decorators.py26__all__ = ["kubernetes"]CODE
LOW…kubernetes/prefect_kubernetes/experimental/__init__.py13__all__ = ["kubernetes"]CODE
LOW…bernetes/prefect_kubernetes/experimental/decorators.py13__all__ = ["kubernetes"]CODE
LOW…integrations/prefect-github/prefect_github/__init__.py6__all__ = ["GitHubCredentials", "GitHubRepository"]CODE
LOW…tegrations/prefect-docker/prefect_docker/decorators.py20__all__ = ["docker"]CODE
LOW…prefect-docker/prefect_docker/experimental/__init__.py12__all__ = ["docker"]CODE
LOW…efect-docker/prefect_docker/experimental/decorators.py13__all__ = ["docker"]CODE
LOW…integrations/prefect-gitlab/prefect_gitlab/__init__.py6__all__ = ["GitLabRepository", "GitLabCredentials"]CODE
LOW…integrations/prefect-aws/infra/worker/service_stack.py410 def _setup_autoscaling(self) -> None:CODE
LOWsrc/integrations/prefect-aws/prefect_aws/__init__.py9__all__ = [CODE
LOWsrc/integrations/prefect-aws/prefect_aws/decorators.py50__all__ = ["ecs"]CODE
LOW…tions/prefect-aws/prefect_aws/experimental/__init__.py12__all__ = ["ecs"]CODE
LOW…ons/prefect-aws/prefect_aws/experimental/decorators.py13__all__ = ["ecs"]CODE
LOW…prefect-aws/prefect_aws/experimental/bundles/upload.py17__all__ = ["UploadResult", "main", "upload_bundle_to_s3"]CODE
LOW…refect-aws/prefect_aws/experimental/bundles/execute.py18__all__ = [CODE
LOW…tegrations/prefect-aws/prefect_aws/workers/__init__.py3__all__ = ["ECSWorker"]CODE
LOW…ntegrations/prefect-aws/prefect_aws/bundles/execute.py32logger = logging.getLogger(__name__)CODE
LOW…ations/prefect-bitbucket/prefect_bitbucket/__init__.py8__all__ = ["BitBucketCredentials", "BitBucketRepository"]CODE
LOW…egrations/prefect-redis/prefect_redis/lease_storage.py22logger = logging.getLogger(__name__)CODE
LOW…c/integrations/prefect-azure/prefect_azure/__init__.py12__all__ = [CODE
LOW…integrations/prefect-azure/prefect_azure/decorators.py26__all__ = ["azure_container_instance"]CODE
LOW…s/prefect-azure/prefect_azure/experimental/__init__.py12__all__ = ["azure_container_instance"]CODE
LOW…prefect-azure/prefect_azure/experimental/decorators.py13__all__ = ["azure_container_instance"]CODE
LOW…ect-azure/prefect_azure/experimental/bundles/upload.py17__all__ = [CODE
LOW…ct-azure/prefect_azure/experimental/bundles/execute.py16__all__ = ["execute_bundle_from_azure_blob_storage", "main"]CODE
LOW…t-azure/prefect_azure/experimental/bundles/__init__.py19__all__ = [CODE
LOW…fect-azure/prefect_azure/workers/container_instance.py137logger = logging.getLogger(__name__)CODE
LOWsrc/prefect/plugins.py40__all__ = [CODE
LOWsrc/prefect/__init__.py177__all__ = [CODE
LOWsrc/prefect/context.py758 def update_tracked_assets(self) -> None:CODE
LOWsrc/prefect/automations.py45__all__ = [CODE
LOWsrc/prefect/main.py66__all__ = [CODE
LOWsrc/prefect/blocks/fields.py3__all__ = ["SecretDict"]CODE
LOWsrc/prefect/blocks/__init__.py7__all__ = ["notifications", "system", "webhook"]CODE
LOWsrc/prefect/_internal/control_listener.py65def _set_intent(value: Intent) -> None:CODE
LOWsrc/prefect/_internal/compatibility/backports.py11__all__ = ["tomllib"]CODE
LOWsrc/prefect/_internal/plugins/startup.py126__all__ = ["run_startup_hooks", "HookContext", "HookSpec", "SetupResult"]CODE
LOWsrc/prefect/_internal/concurrency/calls.py291 def set_timeout(self, timeout: Optional[float] = None) -> None:CODE
LOWsrc/prefect/_internal/concurrency/calls.py302 def set_runner(self, portal: "Portal") -> None:CODE
LOWsrc/prefect/_internal/analytics/__init__.py73__all__ = [CODE
LOWsrc/prefect/settings/__init__.py46__all__ = [ # noqa: F822CODE
86 more matches not shown…
Verbosity Indicators56 hits · 90 pts
SeverityFileLineSnippetContext
LOW…omations/automations-wizard/automation-wizard.test.tsx639 // Step 1: TriggerCOMMENT
LOW…omations/automations-wizard/automation-wizard.test.tsx645 // Step 2: ActionsCOMMENT
LOW…omations/automations-wizard/automation-wizard.test.tsx655 // Step 3: DetailsCOMMENT
LOWexamples/resume_flow_run_on_pr_merge.py26# ## Step 1: Create a Prefect webhookCOMMENT
LOWexamples/resume_flow_run_on_pr_merge.py51# ## Step 2: Configure GitHub webhookCOMMENT
LOWexamples/resume_flow_run_on_pr_merge.py61# ## Step 3: Create an automationCOMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py67# ### Step 1: Fetch Raw DataCOMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py88# ### Step 2: Process the DataCOMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py116# ### Step 3: Create AnalyticsCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1264 # Step 1: full build — populate cacheCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1267 # Step 2: change root SQLCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1270 # Step 3: selective run — only leafCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1277 # Step 4: full build — root/mid rebuild, leaf must NOT cache-hitCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1283 # Step 1: all succeedCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1287 # Step 3: leaf re-executes (cache miss — upstream key changed)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1290 # Step 4: root/mid re-execute (new file content); leaf must alsoCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1315 # Step 1: change root SQLCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1318 # Step 2: selective run — only leafCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1325 # Step 3: selective run — only root and mid (rebuild upstream)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1332 # Step 4: selective run — only leaf againCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1343 # Step 2: leaf executes (cache miss)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1345 # Step 3: root and mid executeCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1348 # Step 4: leaf must re-execute (NOT cache-hit from step 2)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1409 # Step 1: full build — populates execution state for all nodesCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1412 # Step 2: change A's SQLCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1415 # Step 3: selective run — only CCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1422 # Step 4: selective run — only DCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1433 # Step 1: all succeedCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1435 # Step 3: C executes (salted upstream keys since A changed)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1437 # Step 4: D must re-execute, NOT cache-hit, because C wasCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1515 # Step 1: full build — all succeed, execution state populatedCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1518 # Step 2: change mid's SQL so the cache key changes,COMMENT
LOW…ntegrations/prefect-slack/prefect_slack/credentials.py107 # failures. This is not available in older versions, so we need to check if theCOMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py877 # Step 1: Pod is Pending (no issues yet)COMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py911 # Step 2: Pod is still Pending but now has ImagePullBackOffCOMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py982 # Step 1: Pod is Pending and UnschedulableCOMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py1017 # Step 2: Pod transitions to Running (problem resolved)COMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py1072 # Step 1: CrashLoopBackOffCOMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py1105 # Step 2: Pod terminates with OOMKilledCOMMENT
LOWsrc/integrations/prefect-redis/tests/test_ordering.py416 # Step 1: Follower parks itselfCOMMENT
LOWsrc/integrations/prefect-redis/tests/test_ordering.py423 # Step 2: Leader completes, claiming the followerCOMMENT
LOWsrc/integrations/prefect-redis/tests/test_ordering.py431 # Step 3: Simulate follower's double-check pathCOMMENT
LOWsrc/integrations/prefect-redis/tests/test_ordering.py443 # Step 4: Verify event data is STILL available for the leaderCOMMENT
LOWsrc/prefect/runner/runner.py1644 # Step 1: clientCOMMENT
LOWsrc/prefect/runner/runner.py1691 # Step 4: Construct client-dependent services after client is startedCOMMENT
LOWsrc/prefect/runner/runner.py1742 # Step 5: runs_task_groupCOMMENT
LOWsrc/prefect/runner/runner.py1797 # Step 6: Enter observer context manager lastCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py164 # Step 6: remove handle from process_managerCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py168 # Step 7: interpret exit code and propose terminal stateCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py293 # Step 4: CancellationManagerCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py303 # Step 5: Observer enters LAST (starts websocket/polling)COMMENT
LOWsrc/prefect/runner/_flow_run_executor.py132 # Step 2: already-cancelled precheckCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py184 # Step 8: run crashed hooksCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py247 # Step 1: clientCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py267 # Step 2: ProcessManager with observer add/remove callbacksCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py278 # Step 3: StateProposer, placeholder HookRunner, EventEmitterCOMMENT
Structural Annotation Overuse55 hits · 88 pts
SeverityFileLineSnippetContext
LOW…omations/automations-wizard/automation-wizard.test.tsx639 // Step 1: TriggerCOMMENT
LOW…omations/automations-wizard/automation-wizard.test.tsx645 // Step 2: ActionsCOMMENT
LOW…omations/automations-wizard/automation-wizard.test.tsx655 // Step 3: DetailsCOMMENT
LOWexamples/resume_flow_run_on_pr_merge.py26# ## Step 1: Create a Prefect webhookCOMMENT
LOWexamples/resume_flow_run_on_pr_merge.py51# ## Step 2: Configure GitHub webhookCOMMENT
LOWexamples/resume_flow_run_on_pr_merge.py61# ## Step 3: Create an automationCOMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py67# ### Step 1: Fetch Raw DataCOMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py88# ### Step 2: Process the DataCOMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py116# ### Step 3: Create AnalyticsCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1264 # Step 1: full build — populate cacheCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1267 # Step 2: change root SQLCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1270 # Step 3: selective run — only leafCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1277 # Step 4: full build — root/mid rebuild, leaf must NOT cache-hitCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1283 # Step 1: all succeedCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1287 # Step 3: leaf re-executes (cache miss — upstream key changed)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1290 # Step 4: root/mid re-execute (new file content); leaf must alsoCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1315 # Step 1: change root SQLCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1318 # Step 2: selective run — only leafCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1325 # Step 3: selective run — only root and mid (rebuild upstream)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1332 # Step 4: selective run — only leaf againCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1343 # Step 2: leaf executes (cache miss)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1345 # Step 3: root and mid executeCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1348 # Step 4: leaf must re-execute (NOT cache-hit from step 2)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1409 # Step 1: full build — populates execution state for all nodesCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1412 # Step 2: change A's SQLCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1415 # Step 3: selective run — only CCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1422 # Step 4: selective run — only DCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1433 # Step 1: all succeedCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1435 # Step 3: C executes (salted upstream keys since A changed)COMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1437 # Step 4: D must re-execute, NOT cache-hit, because C wasCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1515 # Step 1: full build — all succeed, execution state populatedCOMMENT
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1518 # Step 2: change mid's SQL so the cache key changes,COMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py877 # Step 1: Pod is Pending (no issues yet)COMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py911 # Step 2: Pod is still Pending but now has ImagePullBackOffCOMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py982 # Step 1: Pod is Pending and UnschedulableCOMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py1017 # Step 2: Pod transitions to Running (problem resolved)COMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py1072 # Step 1: CrashLoopBackOffCOMMENT
LOW…integrations/prefect-kubernetes/tests/test_observer.py1105 # Step 2: Pod terminates with OOMKilledCOMMENT
LOWsrc/integrations/prefect-redis/tests/test_ordering.py416 # Step 1: Follower parks itselfCOMMENT
LOWsrc/integrations/prefect-redis/tests/test_ordering.py423 # Step 2: Leader completes, claiming the followerCOMMENT
LOWsrc/integrations/prefect-redis/tests/test_ordering.py431 # Step 3: Simulate follower's double-check pathCOMMENT
LOWsrc/integrations/prefect-redis/tests/test_ordering.py443 # Step 4: Verify event data is STILL available for the leaderCOMMENT
LOWsrc/prefect/runner/runner.py1644 # Step 1: clientCOMMENT
LOWsrc/prefect/runner/runner.py1691 # Step 4: Construct client-dependent services after client is startedCOMMENT
LOWsrc/prefect/runner/runner.py1742 # Step 5: runs_task_groupCOMMENT
LOWsrc/prefect/runner/runner.py1797 # Step 6: Enter observer context manager lastCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py164 # Step 6: remove handle from process_managerCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py168 # Step 7: interpret exit code and propose terminal stateCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py293 # Step 4: CancellationManagerCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py303 # Step 5: Observer enters LAST (starts websocket/polling)COMMENT
LOWsrc/prefect/runner/_flow_run_executor.py132 # Step 2: already-cancelled precheckCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py184 # Step 8: run crashed hooksCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py247 # Step 1: clientCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py267 # Step 2: ProcessManager with observer add/remove callbacksCOMMENT
LOWsrc/prefect/runner/_flow_run_executor.py278 # Step 3: StateProposer, placeholder HookRunner, EventEmitterCOMMENT
Over-Commented Block78 hits · 76 pts
SeverityFileLineSnippetContext
LOWtests/conftest.py41# fires a `UserWarning: The NumPy module was reloaded`, which ourCOMMENT
LOWtests/conftest.py581 yieldCOMMENT
LOWtests/events/server/triggers/test_flow_run_slas.py801COMMENT
LOWdocs/.vale.ini21mdx = mdCOMMENT
LOW…ork-pool-page-header/work-pool-page-header.stories.tsx101 },COMMENT
LOW…ork-pool-page-header/work-pool-page-header.stories.tsx121// ...mockWorkPool,COMMENT
LOWui-v2/src/hooks/use-debounce-callback.tsx61// type SearchProps {COMMENT
LOWui-v2/src/hooks/use-debounce-callback.tsx81// />COMMENT
LOWexamples/hello_world.py1# ---COMMENT
LOWexamples/hello_world.py61 hello(name)COMMENT
LOWexamples/hello_world.py81# For instance, change the greeting message in the `hello` function to a different message and run the flow again.COMMENT
LOWexamples/hello_world.py101#COMMENT
LOWexamples/ai_data_analyst_with_pydantic_ai.py1# ---COMMENT
LOWexamples/ai_data_analyst_with_pydantic_ai.py21# 3. Uses Python tools to calculate statistics and detect anomaliesCOMMENT
LOWexamples/ai_data_analyst_with_pydantic_ai.py281 print("❌ Error: OPENAI_API_KEY environment variable not set")COMMENT
LOWexamples/ai_data_analyst_with_pydantic_ai.py301# ```bashCOMMENT
LOWexamples/ai_data_analyst_with_pydantic_ai.py321# - All operations respect 60s timeoutCOMMENT
LOWexamples/ai_data_analyst_with_pydantic_ai.py341# 4. Trigger a run from the UI (http://localhost:4200) or CLICOMMENT
LOWexamples/run_api_sourced_etl.py1# ---COMMENT
LOWexamples/run_api_sourced_etl.py21# In this article you will:COMMENT
LOWexamples/run_api_sourced_etl.py41#COMMENT
LOWexamples/run_api_sourced_etl.py141# ## Run it!COMMENT
LOWexamples/run_api_sourced_etl.py161# 4. The CSV was written to disk and a preview printed locally (the flow's `log_prints=True` flag logs messages inside tCOMMENT
LOWexamples/run_dbt_with_prefect.py1# ---COMMENT
LOWexamples/run_dbt_with_prefect.py21# > **Note**: This example uses **dbt Core** (the open-source CLI). For dbt Cloud integration, see the [dbt Cloud guide]COMMENT
LOWexamples/run_dbt_with_prefect.py41# ### Running the example locallyCOMMENT
LOWexamples/run_dbt_with_prefect.py261#COMMENT
LOWexamples/run_dbt_with_prefect.py281# - **Event-Driven**: Automatic Prefect events for dbt node status changes enable advanced monitoring and alertingCOMMENT
LOWexamples/resume_flow_run_on_pr_merge.py1# ---COMMENT
LOWexamples/resume_flow_run_on_pr_merge.py21#COMMENT
LOWexamples/resume_flow_run_on_pr_merge.py41# }COMMENT
LOWexamples/resume_flow_run_on_pr_merge.py61# ## Step 3: Create an automationCOMMENT
LOWexamples/resume_flow_run_on_pr_merge.py101if __name__ == "__main__":COMMENT
LOWexamples/resume_flow_run_on_pr_merge.py121# 2. **Webhook transforms event**: The Jinja template extracts the flow run ID from the PR body and creates a Prefect evCOMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py1# ---COMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py21# * **`@materialize` decorator** – Transform functions into versioned, cacheable data assetsCOMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py41# # Follow README for setup and configurationCOMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py181COMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py201# 3. **Storage Integration**COMMENT
LOWexamples/atproto_dashboard_with_prefect_assets.py221# - dbt transformations with DuckDBCOMMENT
LOWexamples/ai_database_cleanup_with_approval.py1# ---COMMENT
LOWexamples/ai_database_cleanup_with_approval.py21# [github.com/zzstoatzz/prefect-mcp-server-demo](https://github.com/zzstoatzz/prefect-mcp-server-demo)COMMENT
LOWexamples/simple_web_scraper.py1# ---COMMENT
LOWexamples/simple_web_scraper.py21#COMMENT
LOWexamples/simple_web_scraper.py121# 2. Applied retry logic to the network call – a flaky connection would auto-retry up to 3 times.COMMENT
LOWexamples/per_worker_task_concurrency.py1# ---COMMENT
LOWexamples/per_worker_task_concurrency.py21# ## Example: Image processing with ML inferenceCOMMENT
LOWexamples/per_worker_task_concurrency.py121COMMENT
LOWexamples/per_worker_task_concurrency.py141# prefect work-pool create ml-pool --type processCOMMENT
LOWexamples/per_worker_task_concurrency.py161#COMMENT
LOWexamples/per_worker_task_concurrency.py181# 1. **GCLs are server-coordinated** — The Prefect server tracks who holds whatCOMMENT
LOWscripts/wait-for-healthy-container.sh1#!/usr/bin/env bashCOMMENT
LOW.github/workflows/codeql-analysis.yml21 # │ ┌───────────── hour (0 - 23)COMMENT
LOW.github/workflows/codspeed-benchmarks.yaml61 with:COMMENT
LOW…egrations/prefect-dbt/prefect_dbt/cloud/credentials.py141 # "packageName": "tpch",COMMENT
LOW…integrations/prefect-dask/prefect_dask/task_runners.py21 for number in range(highest_number):COMMENT
LOW…efect-aws/prefect_aws/experimental/bundles/__init__.py1# Eagerly import the legacy submodules so thatCOMMENT
LOW…c/integrations/prefect-ray/prefect_ray/task_runners.py21 for number in range(highest_number):COMMENT
LOW…c/integrations/prefect-redis/prefect_redis/ordering.py41# How long we'll wait for an in-flight event to be processed for follower handling,COMMENT
LOW…c/integrations/prefect-redis/prefect_redis/ordering.py281 # 3. Follower checks processing -> FalseCOMMENT
18 more matches not shown…
AI Slop Vocabulary29 hits · 68 pts
SeverityFileLineSnippetContext
MEDIUMui/package-lock.json6488 "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.2.tgz",CODE
MEDIUMui/package-lock.json11912 "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.2.tgz",CODE
MEDIUMtests/testing/test_utilites.py156 # Use test harness which starts background threadsCOMMENT
MEDIUMtests/testing/test_utilites.py173 Regression test for issue #19342 - running the test harness multiple timesSTRING
MEDIUMtests/testing/test_utilites.py186 # Run the test harness twice - the second run would fail with the bugCOMMENT
MEDIUMtests/public/flows/test_flow_crashes.py267 # this here, but we do not have robust testing utilities for deployed runs yet.COMMENT
LOWtests/events/client/test_events_subscriber.py98 # The base subscriber for OSS will just use the API URL, which is set to aCOMMENT
LOWtests/logging/test_logs_subscriber.py127 # The base subscriber for OSS will just use the API URL, which is set to aCOMMENT
MEDIUMui-v2/src/routes/runs/index.tsx476 // Use useQuery for paginated flow runs to leverage placeholderData: keepPreviousDataCOMMENT
MEDIUMui-v2/src/routes/runs/index.tsx482 // Use useQuery for paginated task runs to leverage placeholderData: keepPreviousDataCOMMENT
MEDIUMui-v2/src/routes/runs/index.tsx487 // Use useQuery for flow run history (scatter plot) to leverage placeholderData: keepPreviousDataCOMMENT
MEDIUMui-v2/src/routes/flows/index.tsx104 // Use useQuery for paginated flows to leverage placeholderData: keepPreviousDataCOMMENT
MEDIUMui-v2/src/routes/flows/flow.$id.tsx335 // Use useQuery for deployments to leverage placeholderData: keepPreviousDataCOMMENT
MEDIUMui-v2/src/routes/flows/flow.$id.tsx360 // Use useQuery for paginated flow runsto leverage placeholderData: keepPreviousDataCOMMENT
MEDIUMexamples/run_dbt_with_prefect.py19# The result? Your analytics team gets reliable, observable data pipelines that leverage the strengths of both platformsCOMMENT
MEDIUMsrc/integrations/prefect-dbt/tests/core/test_tracker.py491 """Test a comprehensive workflow with multiple nodes and dependencies."""STRING
LOW…grations/prefect-aws/prefect_aws/workers/ecs_worker.py1423 # Ensure the key is removed entirely, not just set to NoneSTRING
LOWsrc/integrations/prefect-azure/tests/test_aci_worker.py447 # If no entrypoint is provided, just use the commandCOMMENT
LOWsrc/prefect/flow_engine.py2226 # parameters, in that case just return the parameters as-is.COMMENT
LOWsrc/prefect/_internal/schemas/validators.py372 # rrule would just create different garbage. The real validatorCOMMENT
MEDIUMsrc/prefect/_internal/concurrency/event_loop.py56 # result of the call. We wrap the call with a future to facilitate retrieval.COMMENT
MEDIUMsrc/prefect/server/models/block_schemas.py658 # ones first (and to facilitate getting the newest one with `limit=1`).COMMENT
LOWsrc/prefect/server/models/work_queues.py93 # work pool was created. We can just return it.COMMENT
LOWsrc/prefect/_sdk/schema_converter.py93 # Handle allOf (intersection - we just use the first one with useful info)COMMENT
MEDIUMsrc/prefect/_sdk/renderer.py435 # Use importlib.resources.files() for robust package resource accessCOMMENT
LOWsrc/prefect/utilities/asyncutils/__init__.py402 # In a sync context and there is no event loop; just create an event loopCOMMENT
LOWsrc/prefect/utilities/templating/__init__.py174 # If there are no values, we can just use the templateCOMMENT
MEDIUMsrc/prefect/testing/utilities.py170 # it after the harness exits, then register the harness server underCOMMENT
LOWsrc/prefect/bundles/_ignore_filter.py197 # Can't make relative - just use nameCOMMENT
Fake / Example Data46 hits · 43 pts
SeverityFileLineSnippetContext
LOWtests/cli/test_work_pool.py750 "Hello world lorem ipsum",CODE
LOWtests/cli/test_work_pool.py758 assert client_res.description == "Hello world lorem ipsum"CODE
LOWtests/cli/cloud/test_cloud.py1024 PREFECT_API_KEY: "fake-key",CODE
LOWtests/cli/cloud/test_cloud.py1045 PREFECT_API_KEY: "fake-key",CODE
LOWtests/cli/cloud/test_cloud.py1075 PREFECT_API_KEY: "fake-key",CODE
LOWtests/cli/cloud/test_cloud.py1096 PREFECT_API_KEY: "fake-key",CODE
LOWtests/cli/cloud/test_cloud.py1123 PREFECT_API_KEY: "fake-key",CODE
LOWtests/cli/cloud/test_cloud.py1144 PREFECT_API_KEY: "fake-key",CODE
LOWtests/cli/cloud/test_cloud.py1176 PREFECT_API_KEY: "fake-key",CODE
LOWtests/cli/cloud/test_cloud.py1234 PREFECT_API_KEY: "fake-key",CODE
LOWtests/cli/cloud/test_cloud.py1309 PREFECT_API_KEY: "fake-key",CODE
LOWtests/cli/cloud/test_cloud.py1345 PREFECT_API_KEY: "fake-key",CODE
LOWtests/client/test_base_client.py936 "Prefect-Csrf-Token": "fake-token",CODE
LOWtests/client/test_base_client.py1038 "Prefect-Csrf-Token": "fake-token",CODE
LOWintegration-tests/test_task_worker.py22CLIENT_DUMMY_API_KEY = "dummy-key-should-be-ignored"CODE
LOWui-v2/src/components/schemas/schema-form.test.tsx91 name: { type: "string", default: "John Doe" },CODE
LOWui-v2/src/components/schemas/schema-form.test.tsx109 expect(spy).toHaveBeenCalledWith({ name: "John Doe" });CODE
LOWui-v2/src/components/schemas/readme.md79By default, the form will use the `default` property to set the initial value of all fields when the form is rendered. ICODE
LOWui-v2/src/components/schemas/readme.md85 name: { type: "string", title: "Name", default: "John Doe" },CODE
LOW…/src/components/schemas/stories/properties.stories.tsx80 default: "John Doe",CODE
LOW…/src/components/schemas/stories/properties.stories.tsx588 name: "John Doe",CODE
LOW…uns/flow-run-details-page/flow-run-details.stories.tsx25 display_value: "John Doe",CODE
LOW…w-runs/flow-run-details-page/flow-run-details.test.tsx135 display_value: "John Doe",CODE
LOW…w-runs/flow-run-details-page/flow-run-details.test.tsx145 expect(screen.getByText("John Doe")).toBeInTheDocument();CODE
LOW…c/integrations/prefect-gcp/tests/test_cloud_storage.py270 "name": ["John Doe", "Jane Doe", "Johny", "Jane"],CODE
LOW…c/integrations/prefect-gcp/tests/test_cloud_storage.py270 "name": ["John Doe", "Jane Doe", "Johny", "Jane"],CODE
LOWsrc/integrations/prefect-docker/tests/test_worker.py1337 "prefect.resource.name": "fake-name",CODE
LOWsrc/integrations/prefect-docker/tests/test_worker.py1346 "prefect.resource.name": "fake-name",CODE
LOWsrc/integrations/prefect-docker/tests/test_worker.py1355 "prefect.resource.name": "fake-name",CODE
LOWsrc/integrations/prefect-docker/tests/test_worker.py56 "Name": "fake-name",CODE
LOWsrc/integrations/prefect-docker/tests/test_worker.py1256 "Docker container fake-name was marked for removal before logs "CODE
LOWsrc/integrations/prefect-docker/tests/test_worker.py1267 assert "Docker container fake-name was marked for removal" in caplog.textCODE
LOWsrc/integrations/prefect-docker/tests/test_worker.py1283 " fake-name." in caplog.textCODE
LOW…rations/prefect-docker/tests/deployments/test_steps.py55 "Name": "fake-name",CODE
LOWsrc/integrations/prefect-aws/tests/test_plugins.py63 mock_client.generate_db_auth_token.return_value = "fake-token"CODE
LOWsrc/integrations/prefect-aws/tests/test_plugins.py76 assert token == "fake-token"CODE
LOWsrc/integrations/prefect-aws/tests/test_utilities.py44 {"op": "add", "path": "/contact/address", "value": "123 Main St"},CODE
LOW…tegrations/prefect-aws/tests/deployments/test_steps.py375 "minio_root_user": "fake_user",CODE
LOWsrc/integrations/prefect-aws/prefect_aws/utilities.py89 {"op": "add", "path": "/contact/address", "value": "123 Main St"},STRING
LOW…tegrations/prefect-bitbucket/tests/test_credentials.py57 token="dummy-token", username="devops.team+ci@scalefocus.com"CODE
LOW…s/prefect-databricks/prefect_databricks/models/jobs.py862 examples=[{"age": 35, "name": "John Doe"}],CODE
LOW…s/prefect-databricks/prefect_databricks/models/jobs.py2535 examples=[{"age": 35, "name": "John Doe"}],CODE
LOW…s/prefect-databricks/prefect_databricks/models/jobs.py3913 "base_parameters": {"age": "35", "name": "John Doe"},CODE
LOW…s/prefect-databricks/prefect_databricks/models/jobs.py4342 "base_parameters": {"age": "35", "name": "John Doe"},CODE
LOWsrc/integrations/prefect-azure/tests/test_plugins.py33 token.token = "fake-token"CODE
LOWsrc/integrations/prefect-azure/tests/test_plugins.py74 assert token == "fake-token"CODE
Overly Generic Function Names20 hits · 20 pts
SeverityFileLineSnippetContext
LOWtests/blocks/test_core.py1706 def do_stuff(self, thing: str):CODE
LOWtests/_internal/compatibility/test_async_dispatch.py23 def my_function() -> None:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py36 def my_function() -> None:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py50 def my_function() -> None:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py73 def my_method(cls) -> str:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py90 def my_method(cls) -> str:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py106 def my_function() -> None:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py118 def my_function() -> None:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py234 def my_function() -> str:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py255 def my_function() -> str:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py276 def my_function() -> str:CODE
LOWtests/_internal/compatibility/test_async_dispatch.py297 def my_function() -> str:CODE
LOWtests/_internal/pydantic/test_validated_func.py506 def process_data(model: MyModel, count: int = 0) -> dict:CODE
LOWtests/telemetry/test_run_telemetry.py55async def run_task(task, task_run_id, parameters, engine_type):CODE
LOWui-v2/public/mockServiceWorker.js122async function handleRequest(event, requestId) {CODE
LOWexamples/atproto_dashboard_with_prefect_assets.py97def process_data(raw_data: dict[str, Any]) -> dict[str, Any]:CODE
LOW…/integrations/prefect-dbt/prefect_dbt/core/_tracker.py145 def run_task():CODE
LOWsrc/prefect/task_engine.py1845def run_task(CODE
LOWsrc/prefect/task_engine.py1858def run_task(CODE
LOWsrc/prefect/task_engine.py1870def run_task(CODE
Synthetic Comment Markers2 hits · 10 pts
SeverityFileLineSnippetContext
HIGH.github/workflows/agents-md-update.yml304 This PR was generated by Claude Code analyzing the diff from the latest push to main and updating any stale AGCODE
HIGH.github/workflows/docs-update.yml151 This PR was generated by Claude Code analyzing source code changes and updating any stale documentation.CODE
AI Response Leakage1 hit · 8 pts
SeverityFileLineSnippetContext
HIGHexamples/simple_web_scraper.py15# In this example you will:COMMENT
Magic Placeholder Names1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHsrc/integrations/prefect-aws/README.md200 -e PREFECT_API_KEY=your-api-key \CODE