Home / PrefectHQ / prefect
Repository Analysis

PrefectHQ/prefect

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

22.3 Moderate AI signal View on GitHub
22.3
Adjusted Score
22.3
Raw Score
100%
Time Factor
2026-05-30
Last Push
22,501
Stars
Python
Language
906,478
Lines of Code
3779
Files
17504
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 31HIGH 703MEDIUM 753LOW 16017

Pattern Findings

17504 matches across 18 categories. Click a row to expand file-level details.

Hyper-Verbose Identifiers13525 hits · 11465 pts
SeverityFileLineSnippet
LOWhatch_build.py27def should_validate_packaged_ui_index_files(root: str | Path) -> bool:
LOWhatch_build.py38def validate_packaged_ui_index_files(root: str | Path) -> None:
LOWui/src/types/automation.ts32export function isAutomationActionFormValues(value: AutomationFormValues): value is AutomationActionFormValues {
LOWui/src/components/AutomationWizardStepTrigger.vue67 function updateTriggerFromJsonString(): AutomationTrigger {
LOWui/src/services/apiStatus.ts12export function setupApiStatusInterceptor(axiosInstance: AxiosInstance): void {
LOWplans/2026-01-12-deployment-crud-events.md140async def _deployment_related_resources(
LOWplans/2026-01-12-deployment-crud-events.md165async def emit_deployment_created_event(
LOWplans/2026-01-12-deployment-crud-events.md179async def emit_deployment_updated_event(
LOWplans/2026-01-12-deployment-crud-events.md197async def emit_deployment_deleted_event(
LOWplans/2025-01-31-per-node-dbt-orchestration.md386def compute_freshness_expiration(
LOWplans/completed/2026-02-18-runner-refactor.md256 def propose_awaiting_retry_sync(self, flow_run: FlowRun) -> None: ...
LOWplans/completed/2026-02-18-runner-refactor.md546 def reschedule_current_flow_runs(self) -> None: ... # sync — uses snapshot(), sync client
LOWplans/completed/2026-02-18-runner-refactor.md583 async def _run_on_cancellation_hooks(self, flow_run: "FlowRun", state: "State") -> None: ...
LOWplans/completed/2026-02-18-runner-refactor.md592 async def _get_and_submit_flow_runs(self) -> None: ... # → _scheduled_run_poller._get_and_subm
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) -> N
LOWplans/completed/2026-02-18-runner-refactor.md596 async def _handle_cancellation_observer_failure(self) -> None: ...
LOWtests/conftest.py163def pytest_collection_modifyitems(
LOWtests/conftest.py266async def restore_loop_after_each_test():
LOWtests/conftest.py296def assert_lifespan_is_not_left_open():
LOWtests/conftest.py424async def generate_test_database_connection_url(
LOWtests/conftest.py506def test_database_connection_url(
LOWtests/conftest.py608def leaves_no_extraneous_files():
LOWtests/test_serializers.py403 def test_does_not_allow_object_hook_collision(self):
LOWtests/test_serializers.py407 def test_does_not_allow_default_collision(self):
LOWtests/test_serializers.py411 def test_pydantic_generic_model_roundtrip(self):
LOWtests/test_serializers.py455 def test_exc_type_rejects_non_exception_class(self):
LOWtests/test_serializers.py461 def test_exc_type_allows_real_exception(self):
LOWtests/test_serializers.py468 def test_exc_type_raises_on_unimportable_class(self):
LOWtests/test_serializers.py474 def test_exc_type_raises_on_dotless_name(self):
LOWtests/test_serializers.py478 def test_class_path_handles_unimportable_class(self):
LOWtests/test_serializers.py484 def test_class_path_handles_dotless_name(self):
LOWtests/test_serializers.py88 def restore_dispatch_registry(self):
LOWtests/test_serializers.py98 def test_serializers_do_not_allow_extra_fields(self):
LOWtests/test_serializers.py111 def test_serializers_can_be_created_by_dict(self):
LOWtests/test_serializers.py127 def test_serializers_can_be_created_by_object(self):
LOWtests/test_serializers.py143 def test_serializers_can_be_created_by_type_string(self):
LOWtests/test_serializers.py165 def test_unknown_serializers_raise_validation_error(self):
LOWtests/test_serializers.py184 def test_simple_roundtrip_with_builtin_pickle(self, data):
LOWtests/test_serializers.py189 def test_picklelib_must_be_string(self):
LOWtests/test_serializers.py206 def test_picklelib_must_implement_dumps(self, monkeypatch: pytest.MonkeyPatch):
LOWtests/test_serializers.py216 def test_picklelib_must_implement_loads(self, monkeypatch: pytest.MonkeyPatch):
LOWtests/test_serializers.py250 def test_simple_roundtrip_with_complex_bytes(self, data: Any):
LOWtests/test_serializers.py263 def test_uses_alternative_json_library(self, monkeypatch: pytest.MonkeyPatch):
LOWtests/test_serializers.py276 def test_json_serializer_does_not_consume_iobase_objects(self):
LOWtests/test_serializers.py337 def test_allows_custom_encoder(self, monkeypatch: pytest.MonkeyPatch):
LOWtests/test_serializers.py362 def test_allows_custom_decoder(self, monkeypatch: pytest.MonkeyPatch):
LOWtests/test_serializers.py386 def test_allows_custom_kwargs(self, monkeypatch: pytest.MonkeyPatch):
LOWtests/test_serializers.py437 def test_dataclass_generic_model_roundtrip(self):
LOWtests/test_serializers.py497 def test_allows_stdlib_compression_libraries(self, lib):
LOWtests/test_serializers.py502 def test_uses_alternative_compression_library(
LOWtests/test_serializers.py515 def test_uses_given_serializer(self, monkeypatch: pytest.MonkeyPatch):
LOWtests/test_infrastructure_bound_flow.py60 def mock_subprocess_check_call(self, monkeypatch: pytest.MonkeyPatch):
LOWtests/test_infrastructure_bound_flow.py113 async def work_pool_without_default_result_storage(
LOWtests/test_infrastructure_bound_flow.py145 async def work_pool_missing_storage_configuration(
LOWtests/test_infrastructure_bound_flow.py160 def test_bind_flow_to_infrastructure(
LOWtests/test_infrastructure_bound_flow.py178 def dragged_through_the_garden():
LOWtests/test_infrastructure_bound_flow.py292 def test_bind_flow_to_infrastructure_normalizes_launcher(
LOWtests/test_infrastructure_bound_flow.py311 def test_bind_flow_to_infrastructure_rejects_invalid_launcher_keys(
LOWtests/test_infrastructure_bound_flow.py329 def test_bind_flow_to_infrastructure_rejects_empty_launcher_override(
LOWtests/test_infrastructure_bound_flow.py344 def test_with_options_preserves_launcher_when_not_provided(
13465 more matches not shown…
Cross-File Repetition329 hits · 1645 pts
SeverityFileLineSnippet
HIGHtests/test_assets.py0test that metadata is still captured when a materializing task succeeds.
HIGHtests/test_assets.py0test that metadata is still captured when a materializing task succeeds.
HIGHtests/test_assets.py0test that metadata is still captured when a materializing task succeeds.
HIGHtests/test_assets.py0test that metadata is still captured when a materializing task succeeds.
HIGHtests/test_task_worker.py0tests for the sync_compatible to async_dispatch migration.
HIGHtests/blocks/test_core.py0tests for the sync_compatible to async_dispatch migration.
HIGHtests/concurrency/v1/test_concurrency_sync.py0tests for the sync_compatible to async_dispatch migration.
HIGHtests/test_flows.py0from prefect import flow @flow def dog(): return "woof!"
HIGHtests/test_flows.py0from prefect import flow @flow def dog(): return "woof!"
HIGHtests/test_flows.py0from prefect import flow @flow def dog(): return "woof!"
HIGHtests/test_flow_engine.py0from prefect import flow @flow def dog(): return "woof!"
HIGHtests/test_flow_engine.py0from prefect import flow @flow def dog(): return "woof!"
HIGHtests/test_flows.py0regression test for https://github.com/prefecthq/prefect/issues/15380
HIGHtests/test_flows.py0regression test for https://github.com/prefecthq/prefect/issues/15380
HIGHtests/test_flows.py0regression test for https://github.com/prefecthq/prefect/issues/15380
HIGHtests/test_flows.py0regression test for https://github.com/prefecthq/prefect/issues/15380
HIGHtests/test_flows.py0\ from prefect import flow @flow def test_flow(): return 1
HIGHtests/test_flows.py0\ from prefect import flow @flow def test_flow(): return 1
HIGHtests/runner/test_storage.py0\ from prefect import flow @flow def test_flow(): return 1
HIGHtests/runner/test_runner.py0\ from prefect import flow @flow def test_flow(): return 1
HIGHtests/deployment/test_steps.py0\ from prefect import flow @flow def test_flow(): return 1
HIGHtests/deployment/test_steps.py0\ from prefect import flow @flow def test_flow(): return 1
HIGHtests/test_flows.py0from prefect import flow @flow def flow_function(name: str) -> str: return name
HIGHtests/test_flows.py0from prefect import flow @flow def flow_function(name: str) -> str: return name
HIGHtests/test_flows.py0from prefect import flow @flow def flow_function(name: str) -> str: return name
HIGHtests/test_filesystems.py0add files and directories to a temporary directory. returns a tuple with the expected parent-level contents and the expe
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 expe
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 expe
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 expe
HIGHtests/test_flow_engine.py0test for generator behavior including stopiteration
HIGHtests/test_flow_engine.py0test for generator behavior including stopiteration
HIGHtests/test_flow_engine.py0test for generator behavior including stopiteration
HIGHtests/test_flow_engine.py0test for generator behavior including stopiteration
HIGHtests/test_task_engine.py0test for generator behavior including stopiteration
HIGHtests/test_task_engine.py0test for generator behavior including stopiteration
HIGHtests/test_task_engine.py0test for generator behavior including stopiteration
HIGHtests/test_task_engine.py0test for generator behavior including stopiteration
HIGHtests/test_flow_engine.py0test that a generator can retry and will re-emit its events
HIGHtests/test_flow_engine.py0test that a generator can retry and will re-emit its events
HIGHtests/test_task_engine.py0test that a generator can retry and will re-emit its events
HIGHtests/test_task_engine.py0test that a generator can retry and will re-emit its events
HIGHtests/test_flow_engine.py0test that a generator doesn't retry for normal generator exceptions like stopiteration
HIGHtests/test_flow_engine.py0test that a generator doesn't retry for normal generator exceptions like stopiteration
HIGHtests/test_task_engine.py0test that a generator doesn't retry for normal generator exceptions like stopiteration
HIGHtests/test_task_engine.py0test that a generator doesn't retry for normal generator exceptions like stopiteration
HIGHtests/test_tasks.py0by default, task transactions are lazy committed and therefore inner tasks do not persist data (i.e., create a cache) un
HIGHtests/test_tasks.py0by default, task transactions are lazy committed and therefore inner tasks do not persist data (i.e., create a cache) un
HIGHtests/test_tasks.py0by default, task transactions are lazy committed and therefore inner tasks do not persist data (i.e., create a cache) un
HIGHtests/test_settings.py0active = "foo" [profiles.foo] prefect_client_retry_extra_codes = "420,500"
HIGHtests/test_settings.py0active = "foo" [profiles.foo] prefect_client_retry_extra_codes = "420,500"
HIGHtests/test_settings.py0active = "foo" [profiles.foo] prefect_client_retry_extra_codes = "420,500"
HIGHtests/test_settings.py0active = "foo" [profiles.foo] prefect_client_retry_extra_codes = "420,500"
HIGHtests/test_settings.py0active = "foo" [profiles.foo] prefect_client_retry_extra_codes = "420,500"
HIGHtests/_experimental/bundles/test_zip_extractor.py0create a zip with the given files. keys are paths, values are content.
HIGHtests/_experimental/bundles/test_zip_extractor.py0create a zip with the given files. keys are paths, values are content.
HIGHtests/_experimental/bundles/test_zip_extractor.py0create a zip with the given files. keys are paths, values are content.
HIGHtests/_experimental/bundles/test_zip_extractor.py0create a zip with the given files. keys are paths, values are content.
HIGHtests/runner/test_runner.py0\ from time import sleep from prefect import flow from prefect.logging.loggers import flow_run_logger def on_cancellatio
HIGHtests/runner/test_runner.py0\ from time import sleep from prefect import flow from prefect.logging.loggers import flow_run_logger def on_cancellatio
HIGHtests/runner/test_runner.py0\ from time import sleep from prefect import flow from prefect.logging.loggers import flow_run_logger def on_cancellatio
269 more matches not shown…
Docstring Block Structure308 hits · 1520 pts
SeverityFileLineSnippet
HIGHplans/2026-01-06-custom-deployment-sdks.md621Get a deployment by name. Args: name: The deployment name in "flow-name/deployment-name" format.
HIGHtests/_internal/compatibility/test_migration.py10 Import an object from a dotted path. This function dynamically imports an object (such as a class, function, o
HIGHtests/runner/test_storage.py121 Format and return the full git URL with GitLab credentials embedded. Handles both personal access toke
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
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.
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 is
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 res
HIGH…ntegrations/prefect-dbt/prefect_dbt/core/_freshness.py64Convert a dbt freshness period specification to a timedelta. Args: count: Number of periods period:
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
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 invocati
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,
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
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 wit
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:
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
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 no
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. Ret
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
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 curre
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.
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1505 Creates a bucket (async version). Args: location: The location of the bucket.
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1536 Creates a bucket. Args: location: The location of the bucket. **create_kwargs:
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 out
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. Ar
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1668 Lists all folders and subfolders in the bucket (async version). Args: folder: List all fol
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1713 Lists all folders and subfolders in the bucket. Args: folder: List all folders and subfold
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py1751 Downloads an object from the object storage service to a path (async version). Args: from_
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 t
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 be
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 objec
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
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
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2067 Uploads an object from a path to the object storage service (async version). Args: from_pa
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
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 a
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
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2255 Uploads files *within* a folder (excluding the folder itself) to the object storage service folder (asy
HIGH…/integrations/prefect-gcp/prefect_gcp/cloud_storage.py2315 Uploads files *within* a folder (excluding the folder itself) to the object storage service folder.
HIGHsrc/integrations/prefect-gcp/prefect_gcp/credentials.py243 Helper method to dynamically get a client type. Args: client_type: The name of the client
HIGHsrc/integrations/prefect-gcp/prefect_gcp/credentials.py267 Gets an authenticated Cloud Storage client. Args: project: Name of the project to use; ove
HIGHsrc/integrations/prefect-gcp/prefect_gcp/credentials.py328 Gets an authenticated BigQuery client. Args: project: Name of the project to use; override
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1093 Fetch a single result from the database (async version). Repeated calls using the same inputs to *any*
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1152 Fetch a single result from the database. Repeated calls using the same inputs to *any* of the fetch me
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1210 Fetch a limited number of results from the database (async version). Repeated calls using the same inp
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1277 Fetch a limited number of results from the database. Repeated calls using the same inputs to *any* of
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1341 Fetch all results from the database (async version). Repeated calls using the same inputs to *any* of
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1398 Fetch all results from the database. Repeated calls using the same inputs to *any* of the fetch method
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1453 Executes an operation on the database (async version). This method is intended to be used for operation
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1501 Executes an operation on the database. This method is intended to be used for operations that do not re
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1546 Executes many operations on the database (async version). This method is intended to be used for operat
HIGHsrc/integrations/prefect-gcp/prefect_gcp/bigquery.py1598 Executes many operations on the database. This method is intended to be used for operations that do not
HIGH…ations/prefect-gcp/prefect_gcp/workers/cloud_run_v2.py997 Check whether a transient submission error actually started an execution. Submitting a Cloud Run job i
HIGH…ations/prefect-gcp/prefect_gcp/workers/cloud_run_v2.py1250 Update execution status until it is no longer running. Args: cr_client (Resource): The bas
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
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: The
HIGH…refect-kubernetes/prefect_kubernetes/custom_objects.py139Task for reading a namespaced Kubernetes custom object. Args: kubernetes_credentials: `KubernetesCredential
HIGH…refect-kubernetes/prefect_kubernetes/custom_objects.py313Task for patching a namespaced custom resource. Args: kubernetes_credentials: KubernetesCredentials block
HIGH…refect-kubernetes/prefect_kubernetes/custom_objects.py386Task for replacing a namespaced custom resource. Args: kubernetes_credentials: KubernetesCredentials block
HIGH…s/prefect-kubernetes/prefect_kubernetes/credentials.py205 Utility function for configuring a generic Kubernetes client. It will attempt to connect to a Kubernete
HIGH…grations/prefect-kubernetes/prefect_kubernetes/jobs.py174Task for patching a namespaced Kubernetes job. Args: kubernetes_credentials: KubernetesCredentials block
248 more matches not shown…
Decorative Section Separators373 hits · 1394 pts
SeverityFileLineSnippet
MEDIUMplans/completed/2026-02-18-runner-refactor.md560 # ── Internal attributes — tests access these directly ────────────────────────
MEDIUMplans/completed/2026-02-18-runner-refactor.md576 # ── Private method passthroughs ──────────────────────────────────────────────
MEDIUMtests/test_assets.py286# =============================================================================
MEDIUMtests/test_assets.py288# =============================================================================
MEDIUMtests/test_assets.py389# =============================================================================
MEDIUMtests/test_assets.py391# =============================================================================
MEDIUMtests/test_assets.py450# =============================================================================
MEDIUMtests/test_assets.py452# =============================================================================
MEDIUMtests/test_assets.py1045# =============================================================================
MEDIUMtests/test_assets.py1047# =============================================================================
MEDIUMtests/test_assets.py1230# =============================================================================
MEDIUMtests/test_assets.py1232# =============================================================================
MEDIUMtests/test_assets.py1312# =============================================================================
MEDIUMtests/test_assets.py1314# =============================================================================
MEDIUMtests/test_assets.py1412# =============================================================================
MEDIUMtests/test_assets.py1414# =============================================================================
MEDIUMtests/test_assets.py52# =============================================================================
MEDIUMtests/test_assets.py54# =============================================================================
MEDIUMtests/test_assets.py678# =============================================================================
MEDIUMtests/test_assets.py680# =============================================================================
MEDIUMtests/test_subprocess_logging.py15# ---------------------------------------------------------------------------
MEDIUMtests/test_subprocess_logging.py17# ---------------------------------------------------------------------------
MEDIUMtests/test_subprocess_logging.py44# ---------------------------------------------------------------------------
MEDIUMtests/test_subprocess_logging.py46# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py92# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py94# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py136# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py138# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py197# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py199# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py268# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py270# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py297# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py299# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py525# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py527# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py543# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py545# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py599# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py601# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py679# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py681# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py14# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__scheduled_run_poller.py16# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__flow_run_executor.py147# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__flow_run_executor.py149# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__flow_run_executor.py444# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__flow_run_executor.py446# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__flow_run_executor.py18# ---------------------------------------------------------------------------
MEDIUMtests/runner/test__flow_run_executor.py20# ---------------------------------------------------------------------------
MEDIUMtests/server/services/test_db_vacuum.py157# ---------------------------------------------------------------------------
MEDIUMtests/server/services/test_db_vacuum.py159# ---------------------------------------------------------------------------
MEDIUMtests/server/services/test_db_vacuum.py46# ---------------------------------------------------------------------------
MEDIUMtests/server/services/test_db_vacuum.py48# ---------------------------------------------------------------------------
MEDIUMtests/events/server/triggers/test_flow_run_slas.py810# ------------------------------------------------------
MEDIUM…ents/server/actions/test_pausing_resuming_work_pool.py324# -----------------------------------------------------
MEDIUM…ents/server/actions/test_pausing_resuming_work_pool.py330# -----------------------------------------------------
MEDIUMexamples/run_api_sourced_etl.py67# ---------------------------------------------------------------------------
MEDIUMexamples/run_api_sourced_etl.py69# ---------------------------------------------------------------------------
MEDIUMexamples/run_api_sourced_etl.py83# ---------------------------------------------------------------------------
313 more matches not shown…
Unused Imports1255 hits · 1165 pts
SeverityFileLineSnippet
LOWhatch_build.py1
LOWtools/write_build_info.py1
LOWtests/conftest.py50
LOWtests/conftest.py95
LOWtests/conftest.py96
LOWtests/conftest.py98
LOWtests/conftest.py99
LOWtests/conftest.py100
LOWtests/conftest.py101
LOWtests/conftest.py102
LOWtests/conftest.py103
LOWtests/conftest.py104
LOWtests/conftest.py105
LOWtests/conftest.py106
LOWtests/conftest.py107
LOWtests/conftest.py108
LOWtests/test_infrastructure_bound_flow.py1
LOWtests/test_logging.py1
LOWtests/test_logging.py89
LOWtests/test_logging.py89
LOWtests/test_logging.py90
LOWtests/test_filesystems.py696
LOWtests/test_versioning.py1
LOWtests/test_transactions.py1
LOWtests/test_flows_compat.py1
LOWtests/test_ui_build_validation.py1
LOWtests/test_background_tasks.py26
LOWtests/test_types.py1
LOWtests/test_settings.py1
LOWtests/blocks/conftest.py8
LOWtests/_internal/test_control_listener.py3
LOWtests/docker/test_docker_image.py1
LOWtests/docker/test_buildx.py3
LOWtests/_experimental/bundles/test_zip_extractor.py8
LOWtests/_experimental/bundles/test_zip_builder.py8
LOW…experimental/bundles/test_include_files_integration.py8
LOW…ts/_experimental/bundles/test_dependency_validation.py3
LOWtests/_experimental/bundles/test_ignore_filter.py16
LOWtests/_experimental/bundles/test_execute.py1
LOWtests/_experimental/bundles/test_file_collector.py12
LOWtests/_experimental/bundles/test_path_resolver.py9
LOWtests/plugins/test_plugins.py5
LOWtests/plugins/test_compat.py10
LOWtests/runner/test__scheduled_run_poller.py1
LOWtests/runner/test__deployment_registry.py1
LOWtests/runner/test__workspace_resolver.py1
LOWtests/runner/test__starter_bundle.py1
LOWtests/runner/test__workspace_starter.py1
LOWtests/runner/test__flow_run_executor.py1
LOWtests/runner/test__cancellation_manager.py1
LOWtests/runner/test__process_manager.py1
LOWtests/runner/test__state_proposer.py1
LOWtests/runner/test_runner.py1
LOWtests/runner/test__control_channel.py3
LOWtests/runner/test_control_channel_e2e.py19
LOWtests/runner/test__starter_engine.py1
LOWtests/runner/test__event_emitter.py1
LOWtests/runner/test__flow_resolver.py1
LOWtests/runner/test__hook_runner.py1
LOWtests/runner/test__starter_direct.py1
1195 more matches not shown…
Self-Referential Comments331 hits · 1055 pts
SeverityFileLineSnippet
MEDIUMtests/conftest.py387 # Create the storage path now, fixing an obscure bug where it can be created by
MEDIUMtests/conftest.py457 # Create an empty temporary database for use in the tests
MEDIUMtests/test_infrastructure_bound_flow.py913 # Create an initial flow run using the client directly
MEDIUMtests/test_infrastructure_bound_flow.py961 # Create an initial flow run using the client directly
MEDIUMtests/test_filesystems.py314 # Create a real file
MEDIUMtests/test_filesystems.py318 # Create a symlink within the source directory
MEDIUMtests/test_filesystems.py322 # Create a destination directory
MEDIUMtests/test_filesystems.py345 # Create a real file
MEDIUMtests/test_filesystems.py349 # Create a symlink within the source directory
MEDIUMtests/test_filesystems.py353 # Create a destination directory
MEDIUMtests/test_futures.py89 # Create a slow future first, then fast ones
MEDIUMtests/test_futures.py661 # Create a new future instance (simulating getting the future from delay())
MEDIUMtests/test_artifacts.py998 # Create an artifact first
MEDIUMtests/test_artifacts.py1017 # Create an artifact first
MEDIUMtests/test_transactions.py723 # Create a result store with explicit NullFileSystem for metadata_storage
MEDIUMtests/test_transactions.py825 # Create a result store with explicit NullFileSystem for metadata_storage
MEDIUMtests/test_cache_policies.py222 # Create a compound policy with multiple Inputs policies
MEDIUMtests/test_flow_engine.py5139 # Create a flow run with a deployment
MEDIUMtests/test_context.py438 # Create a deployment and avoid red squiggles
MEDIUMtests/test_context.py448 # Create a flow run from the deployment
MEDIUMtests/test_context.py453 # Define a wrapper function to ensure environment variables and settings propagate because
MEDIUMtests/test_context.py465 # Create a new settings object to pick up the new environment variables
MEDIUMtests/test_settings.py2865 # Create a new settings instance to pick up the env var
MEDIUMtests/test_settings.py2986 # Create a new settings instance that will load from the profiles file
MEDIUMtests/_internal/concurrency/test_services.py342 # Creating an instance from an async context is not always safe when sending an
MEDIUMtests/_internal/pydantic/test_validated_func.py428 # Define a test module namespace that simulates using future annotations
MEDIUMtests/_internal/pydantic/test_validated_func.py431 # Create a model in that namespace
MEDIUMtests/_internal/pydantic/test_validated_func.py445 # Define a function with the model as a parameter using string annotation
MEDIUMtests/_internal/pydantic/test_validated_func.py456 # Create an instance of the model
MEDIUMtests/_internal/analytics/conftest.py80 # Create a fresh Prefect home in tmp_path
MEDIUMtests/_experimental/bundles/test_zip_extractor.py765 # Create a valid zip
MEDIUMtests/_experimental/bundles/test_bundles.py102 # Create a mock flow run
MEDIUMtests/_experimental/bundles/test_bundles.py291 # Create a flow with include_files
MEDIUMtests/_experimental/bundles/test_zip_builder.py387 # Create a file that will produce a zip >= 50MB
MEDIUM…experimental/bundles/test_include_files_integration.py421 # Create a sidecar zip
MEDIUM…experimental/bundles/test_include_files_integration.py444 # Create a helper script that copies files preserving directory structure
MEDIUM…experimental/bundles/test_include_files_integration.py690 # Create a real flow file
MEDIUM…experimental/bundles/test_include_files_integration.py720 # Create a flow and set include_files (as @ecs decorator would)
MEDIUMtests/_experimental/bundles/test_file_collector.py1137 # Create a file slightly over threshold
MEDIUMtests/_experimental/bundles/test_path_resolver.py715 # Create a test file
MEDIUMtests/_experimental/bundles/test_path_resolver.py729 # Create a file outside the base directory
MEDIUMtests/_experimental/bundles/test_path_resolver.py685 # Create a test file
MEDIUMtests/_experimental/bundles/test_path_resolver.py809 # Create a subdirectory
MEDIUMtests/_experimental/bundles/test_path_resolver.py822 # Create a dotfile
MEDIUMtests/_experimental/bundles/test_path_resolver.py895 # Create the parent structure to ensure file exists
MEDIUMtests/input/test_run_input.py757 # Create a model with initial data
MEDIUMtests/plugins/test_plugins.py272 # Create a mock module with a function-based plugin
MEDIUMtests/plugins/test_plugins.py296 # Create a mock module with an async function-based plugin
MEDIUMtests/runner/test_runner.py1195 # Create a mock flow run
MEDIUMtests/runner/test_runner.py2760 # Create an instance and add its flow method
MEDIUMtests/runner/test_runner.py2787 # Create an instance and add its flow method with cancellation hook
MEDIUMtests/runner/test_runner.py2831 # Create an instance and add its flow method with crashed hook
MEDIUMtests/locking/test_filelock.py74 # Create a stale lock with a dead PID
MEDIUMtests/locking/test_filelock.py167 # Create a lock held by "this process" so it won't be detected
MEDIUMtests/server/models/test_flow_runs.py310 # Create a flow run with no labels
MEDIUMtests/server/models/test_flow_runs.py269 # Create a flow run with initial labels
MEDIUMtests/server/models/test_csrf_token.py46 # Create a token
MEDIUMtests/server/models/test_deployments.py272 # Create a global concurrency limit first
MEDIUMtests/server/models/test_deployments.py1114 # Create a deployment with custom labels
MEDIUMtests/server/models/test_deployments.py1159 # Create a deployment with custom labels and schedules
271 more matches not shown…
Excessive Try-Catch Wrapping529 hits · 533 pts
SeverityFileLineSnippet
LOWtests/test_logging.py1778 except Exception:
LOWtests/test_logging.py1855 except Exception as exc: # noqa
LOWtests/test_flows.py2124 except Exception:
LOWtests/test_exceptions.py55 except Exception as exc:
LOWtests/test_exceptions.py65 except Exception as exc:
MEDIUMtests/test_exceptions.py52def test_pickle_roundtrip_single_error(self):
MEDIUMtests/test_exceptions.py62def test_pickle_roundtrip_two_errors(self):
MEDIUMtests/test_tasks.py1429def test_flow():
LOWtests/test_tasks.py3936 except Exception:
LOWtests/test_tasks.py5496 except Exception:
LOWtests/_internal/test_control_listener.py46 except Exception:
LOWtests/_internal/test_control_listener.py66 except Exception:
LOWtests/_internal/compatibility/test_migration.py57 except Exception as exc:
LOWtests/utilities/test_importtools.py471 except Exception as e:
LOWtests/utilities/test_pydantic.py40except Exception as exc:
LOWtests/utilities/test_dockerutils.py17except Exception:
LOWtests/utilities/test_urls.py484 except Exception:
LOWtests/events/client/test_events_client.py445 except Exception as e:
LOWintegration-tests/test_task_worker.py73 except Exception as e:
LOWintegration-tests/test_flow_suspension.py59 except Exception as exc:
LOWintegration-tests/test_nested_cancellation.py99 except Exception as exc: # pragma: no cover - diagnostic path
LOWintegration-tests/test_client_context_lifespan.py112 except Exception as e:
MEDIUMintegration-tests/test_client_context_lifespan.py113 print(f"Error entering client many times {e}")
MEDIUMintegration-tests/test_client_context_lifespan.py35def lifespan(app):
LOWintegration-tests/test_load_flows_concurrently.py37 except Exception as e:
LOWintegration-tests/test_worker.py35 except Exception:
LOWintegration-tests/test_schedule_statefulness.py49 except Exception as e:
MEDIUMintegration-tests/test_schedule_statefulness.py50 print(f"Error checking schedules: {e}")
LOWintegration-tests/test_runner_resilience.py76 except Exception as e:
LOWintegration-tests/test_runner_resilience.py83 except Exception as e:
LOWui-v2/e2e/helpers/run_flows.py172 except Exception as e:
MEDIUMui-v2/e2e/helpers/run_flows.py173 print(f"Error running scenario '{args.scenario}': {e}", file=sys.stderr)
LOWexamples/ai_database_cleanup_with_approval.py255 except Exception as e:
LOWscripts/backfill_release_notes.py321 except Exception:
LOWscripts/run-integration-flows.py47 except Exception as e:
MEDIUMscripts/run-integration-flows.py48 print(f"Error running {script}: {e}")
LOWscripts/all_links_should_be_ok.py38 except Exception:
LOWscripts/all_links_should_be_ok.py48 except Exception as exc:
LOWscripts/wait-for-server.py53 except Exception as exc:
MEDIUMscripts/prepare_release_notes.py89 print(f"Error generating release notes: {e}")
LOWscripts/prepare_release_notes.py339 except Exception:
MEDIUMscripts/prepare_release_notes.py452 print(f"Error: Invalid version format '{version}'. Expected format: X.Y.Z")
MEDIUMscripts/prepare_release_notes.py459 print(f"Error: Could not parse version '{version}'")
MEDIUMscripts/prepare_integration_release_notes.py58 print(f"Error running command {' '.join(cmd)}: {e}", file=sys.stderr)
LOWscripts/prepare_integration_release_notes.py122 except Exception:
MEDIUMscripts/prepare_integration_release_notes.py354 print(f"Error: Package '{args.package}' not found.", file=sys.stderr)
LOWscripts/test_unc_paths.py64 except Exception as e:
MEDIUMscripts/test_unc_paths.py65 print(f"Error: {type(e).__name__}: {e}")
LOWscripts/generate_mintlify_openapi_docs.py113 except Exception:
MEDIUMscripts/generate_api_ref.py35 print(f"Error generating API reference: {result.stderr}", file=sys.stderr)
LOW…integrations/prefect-dbt/prefect_dbt/core/_manifest.py619 except Exception:
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py743 except Exception as e:
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1286 except Exception as exc:
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1364 except Exception:
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1392 except Exception as exc:
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1578 except Exception:
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1593 except Exception as exc:
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1942 except Exception:
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1975 except Exception:
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py2189 except Exception as exc:
469 more matches not shown…
Deep Nesting421 hits · 360 pts
SeverityFileLineSnippet
LOWtests/conftest.py571
LOWtests/test_flows.py2070
LOWtests/test_settings.py2646
LOWtests/_internal/concurrency/test_cancellation.py364
LOWtests/_internal/concurrency/test_cancellation.py395
LOWtests/_internal/concurrency/test_cancellation.py416
LOWtests/_internal/concurrency/test_cancellation.py456
LOWtests/_internal/concurrency/test_cancellation.py500
LOWtests/_internal/concurrency/test_cancellation.py539
LOWtests/_internal/concurrency/test_cancellation.py561
LOWtests/_internal/concurrency/test_cancellation.py566
LOWtests/experimental/test_bundles.py854
LOWtests/plugins/test_plugins.py479
LOWtests/plugins/test_plugins.py562
LOWtests/runner/test_control_channel_e2e.py63
LOWtests/runner/test__starter_engine.py196
LOWtests/runner/test__starter_engine.py399
LOWtests/runner/test__starter_engine.py433
LOWtests/server/models/test_filters.py51
LOW…sts/server/orchestration/api/test_flow_run_graph_v2.py41
LOWtests/server/orchestration/api/test_workers.py3775
LOWtests/server/orchestration/api/ui/test_task_runs.py181
LOWtests/cli/test_start_server.py49
LOWtests/cli/test_deploy.py2728
LOWtests/cli/test_deploy.py2762
LOWtests/cli/test_transfer.py30
LOWtests/concurrency/test_leases.py108
LOWtests/workers/test_cleanup.py886
LOWtests/events/server/triggers/test_flow_run_slas.py761
LOW…/events/server/models/test_automation_notifications.py120
LOW…s/events/server/actions/test_jinja_templated_action.py652
LOW…s/events/server/actions/test_jinja_templated_action.py661
LOWtests/infrastructure/provisioners/test_cloud_run.py241
LOWtests/infrastructure/provisioners/test_cloud_run.py242
LOWtests/infrastructure/provisioners/test_cloud_run_v2.py211
LOWtests/infrastructure/provisioners/test_cloud_run_v2.py212
LOWtests/infrastructure/provisioners/test_ecs.py971
LOWtests/infrastructure/provisioners/test_ecs.py986
LOWscripts/generate_settings_ref.py13
LOWscripts/generate_settings_ref.py55
LOWscripts/backfill_release_notes.py102
LOWscripts/prepare_release_notes.py104
LOWscripts/prepare_release_notes.py345
LOWscripts/prepare_release_notes.py399
LOWscripts/prepare_integration_release_notes.py167
LOWscripts/prepare_integration_release_notes.py361
LOWscripts/generate_cli_docs.py97
LOWscripts/generate_example_pages.py70
LOWscripts/verify_test_selection.py38
LOWscripts/generate_mintlify_openapi_docs.py39
LOWscripts/pyright_diff.py60
LOW…integrations/prefect-dbt/prefect_dbt/core/_manifest.py361
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py795
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py880
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1013
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1095
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1345
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1596
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1711
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py1807
361 more matches not shown…
Hallucination Indicators31 hits · 315 pts
SeverityFileLineSnippet
CRITICALtests/cli/test_api_command.py165 assert route.calls.last.request.headers.get("X-Custom") == "value"
CRITICALtests/cli/test_api_command.py190 assert route.calls.last.request.headers.get("X-Custom-1") == "value1"
CRITICALtests/cli/test_api_command.py191 assert route.calls.last.request.headers.get("X-Custom-2") == "value2"
CRITICALsrc/integrations/prefect-dbt/tests/cloud/test_jobs.py243 request_body = json.loads(respx_mock.calls.last.request.content.decode())
CRITICALsrc/integrations/prefect-dbt/tests/cloud/test_jobs.py1623 request_body = json.loads(respx_mock.calls.last.request.content.decode())
CRITICALsrc/integrations/prefect-dbt/tests/cloud/test_jobs.py1650 request_body = json.loads(respx_mock.calls.last.request.content.decode())
CRITICAL…owflake/prefect_snowflake/experimental/workers/spcs.py23from snowflake.core.exceptions import NotFoundError
CRITICAL…efect-snowflake/tests/experimental/test_spcs_worker.py1819 from snowflake.core.exceptions import NotFoundError
CRITICAL…efect-snowflake/tests/experimental/test_spcs_worker.py534 from snowflake.core.exceptions import NotFoundError
CRITICAL…efect-snowflake/tests/experimental/test_spcs_worker.py1188 from snowflake.core.exceptions import NotFoundError
CRITICALsrc/integrations/prefect-docker/tests/test_images.py34 client.__enter__.return_value.images.pull.assert_called_once_with(
CRITICALsrc/integrations/prefect-docker/tests/test_images.py56 client.__enter__.return_value.images.pull.assert_called_once_with(
CRITICALsrc/integrations/prefect-docker/tests/test_images.py70 client.__enter__.return_value.images.pull.assert_called_once_with(**pull_kwargs)
CRITICALsrc/integrations/prefect-docker/tests/test_worker.py1584 mock_docker_client.containers.get.return_value.stop.assert_called_once_with(
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py32 client.__enter__.return_value.containers.create.assert_called_once_with(
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py47 client.__enter__.return_value.containers.get.assert_called_once_with("42")
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py60 client.__enter__.return_value.containers.get.assert_called_once_with("42")
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py73 client.__enter__.return_value.containers.get.assert_called_once_with("42")
CRITICAL…c/integrations/prefect-docker/tests/test_containers.py86 client.__enter__.return_value.containers.get.assert_called_once_with("42")
CRITICAL…rations/prefect-docker/tests/deployments/test_steps.py197 mock_docker_client.images.get.return_value.tag.assert_has_calls(
CRITICAL…rations/prefect-docker/tests/deployments/test_steps.py206 mock_docker_client.images.get.return_value.tag.assert_called_once_with(
CRITICAL…rations/prefect-docker/tests/deployments/test_steps.py654 mock_docker_client.images.get.return_value.tag.assert_called_once_with(
CRITICAL…rations/prefect-docker/tests/deployments/test_steps.py676 mock_docker_client.images.get.return_value.tag.assert_called_once_with(
CRITICALsrc/integrations/prefect-azure/tests/conftest.py4from azure.core.exceptions import ResourceExistsError
CRITICALsrc/integrations/prefect-azure/tests/test_aci_worker.py12from azure.core.exceptions import HttpResponseError, ResourceNotFoundError
CRITICAL…/integrations/prefect-azure/tests/test_blob_storage.py6from azure.core.exceptions import ResourceExistsError
CRITICAL…efect-azure/tests/experimental/bundles/test_execute.py8from azure.core.exceptions import ResourceNotFoundError
CRITICAL…refect-azure/tests/experimental/bundles/test_upload.py5from azure.core.exceptions import ResourceExistsError
CRITICAL…tegrations/prefect-azure/prefect_azure/blob_storage.py8from azure.core.exceptions import ResourceNotFoundError
CRITICAL…fect-azure/prefect_azure/workers/container_instance.py81from azure.core.exceptions import HttpResponseError, ResourceNotFoundError
CRITICALsrc/prefect/tasks.py186 context.task.fn.__code__.co_code.hex(),
Cross-Language Confusion63 hits · 255 pts
SeverityFileLineSnippet
HIGHtests/docker/test_docker_image.py71 image.push()
HIGHtests/docker/test_docker_image.py88 image.push() # should not raise
HIGHtests/docker/test_docker_image.py217 image.push()
HIGHtests/docker/test_docker_image.py233 image.push()
HIGHtests/docker/test_docker_image.py197 image.push()
HIGHtests/server/database/test_migrations.py815 "INSERT INTO flow_run_notification_policy (is_active, state_names, tags, message_template, block_doc
HIGHtests/server/orchestration/api/test_work_queues.py1608 when they entered the PENDING state, not start_time (which is null)."""
HIGHtests/_sdk/test_schema_converter_unions.py7 """Test conversion of nullable (anyOf with null) types."""
HIGHtests/_sdk/test_schema_converter_unions.py153 e.g., anyOf: [ {"type":"array","items":{"anyOf":[str, int]}}, null ]
HIGHtests/deployment/test_steps.py1530 "echo first && echo second",
HIGHsrc/integrations/prefect-github/prefect_github/user.py2356 privacy: If non-null, filters repositories
HIGHsrc/integrations/prefect-github/prefect_github/user.py2360 is_locked: If non-null, filters repositories
HIGHsrc/integrations/prefect-github/prefect_github/user.py2364 contribution_types: If non-null, include
HIGHsrc/integrations/prefect-github/prefect_github/user.py532 privacy: If non-null, filters repositories according to privacy.
HIGHsrc/integrations/prefect-github/prefect_github/user.py543 is_locked: If non-null, filters repositories according to
HIGHsrc/integrations/prefect-github/prefect_github/user.py1143 privacy: If non-null, filters repositories according to
HIGHsrc/integrations/prefect-github/prefect_github/user.py1155 is_locked: If non-null, filters repositories according to
HIGHsrc/integrations/prefect-github/prefect_github/user.py1163 is_fork: If non-null, filters repositories according to
HIGH…c/integrations/prefect-github/prefect_github/viewer.py2108 privacy: If non-null, filters repositories
HIGH…c/integrations/prefect-github/prefect_github/viewer.py2112 is_locked: If non-null, filters repositories
HIGH…c/integrations/prefect-github/prefect_github/viewer.py2116 contribution_types: If non-null, include
HIGH…c/integrations/prefect-github/prefect_github/viewer.py476 privacy: If non-null, filters repositories according to privacy.
HIGH…c/integrations/prefect-github/prefect_github/viewer.py487 is_locked: If non-null, filters repositories according to
HIGH…c/integrations/prefect-github/prefect_github/viewer.py1021 privacy: If non-null, filters repositories according to
HIGH…c/integrations/prefect-github/prefect_github/viewer.py1033 is_locked: If non-null, filters repositories according to
HIGH…c/integrations/prefect-github/prefect_github/viewer.py1041 is_fork: If non-null, filters repositories according to
HIGH…grations/prefect-github/prefect_github/organization.py128 privacy: If non-null, filters teams according to privacy.
HIGH…grations/prefect-github/prefect_github/organization.py129 role: If non-null, filters teams according to whether the viewer
HIGH…grations/prefect-github/prefect_github/organization.py131 query: If non-null, filters teams with query on team name and team
HIGH…grations/prefect-github/prefect_github/organization.py944 privacy: If non-null, filters repositories according to
HIGH…grations/prefect-github/prefect_github/organization.py956 is_locked: If non-null, filters repositories according to
HIGH…grations/prefect-github/prefect_github/organization.py964 is_fork: If non-null, filters repositories according to
HIGH…tegrations/prefect-github/prefect_github/repository.py436 privacy: If non-null, filters repositories according to privacy.
HIGH…tegrations/prefect-github/prefect_github/repository.py447 is_locked: If non-null, filters repositories according to whether
HIGH…ions/prefect-github/prefect_github/repository_owner.py133 privacy: If non-null, filters repositories according to
HIGH…ions/prefect-github/prefect_github/repository_owner.py145 is_locked: If non-null, filters repositories according to
HIGH…ions/prefect-github/prefect_github/repository_owner.py153 is_fork: If non-null, filters repositories according to
HIGH…c/integrations/prefect-dask/tests/test_task_runners.py392 assert result.equals(pd.Series([3, 6], index=["x", "y"]))
HIGH…ons/prefect-docker/prefect_docker/deployments/steps.py532 client.api.push(
HIGH…ons/prefect-docker/prefect_docker/deployments/steps.py538 client.api.push(
HIGH…grations/prefect-aws/prefect_aws/workers/ecs_worker.py325 "the task when it is launching. If this value is not null, it will "
HIGH…grations/prefect-aws/prefect_aws/workers/ecs_worker.py546 "not null, it will override the value in the task definition. This value "
HIGH…grations/prefect-aws/prefect_aws/workers/ecs_worker.py607 "the task when it is launching. If this value is not null, it will "
HIGH…grations/prefect-aws/prefect_aws/workers/ecs_worker.py619 "If using the 'awsvpc' network mode and this field is null, your default "
HIGH…tions/prefect-aws/prefect_aws/observers/diagnostics.py70 # --- Container exit code analysis (non-zero or null) -------------------
HIGHsrc/integrations/prefect-shell/tests/test_commands.py127 command="echo $HOME && echo $TEST_VAR",
HIGHsrc/prefect/serializers.py298 level: If not null, the level of compression to pass to `compress`.
HIGHsrc/prefect/states.py463 If the state result is null, a wrapper exception will be returned with the state
HIGHsrc/prefect/states.py549 If the state result is null, a wrapper exception will be returned with the state
HIGHsrc/prefect/_internal/buildx.py211 python_on_whales.docker.image.push(full_name)
HIGHsrc/prefect/docker/docker_image.py162 events = client.api.push(
HIGHsrc/prefect/server/database/query_components.py235 # if null, no limit will be applied
HIGH…04_09_125712_cc510aec4689_automation_event_follower.py48 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n
HIGH…4_03_13_111316_bacc60edce16_create_csrf_token_toble.py35 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n
HIGH…e/2024_04_03_111618_07ed05dfd4ec_automations_models.py58 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n
HIGH…e/2024_04_03_111618_07ed05dfd4ec_automations_models.py120 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n
HIGH…e/2024_04_03_111618_07ed05dfd4ec_automations_models.py175 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n
HIGH…e/2024_04_03_111618_07ed05dfd4ec_automations_models.py246 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n
HIGH…e/2024_04_10_104304_824e9edafa60_adds_events_tables.py37 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n
HIGH…e/2024_04_10_104304_824e9edafa60_adds_events_tables.py111 "(\n (\n lower(hex(randomblob(4)))\n || '-'\n || lower(hex(randomblob(2)))\n
3 more matches not shown…
Redundant / Tautological Comments129 hits · 190 pts
SeverityFileLineSnippet
LOWtests/conftest.py337 # Set PREFECT_HOME to a temporary directory to avoid clobbering
LOWtests/test_flow_engine.py4874 # Set heartbeat_frequency to enable heartbeats
LOWtests/test_flow_engine.py4939 # Set heartbeat_frequency to None (disabled)
LOWtests/test_flow_engine.py4967 # Set heartbeat_frequency to None (disabled)
LOWtests/server/orchestration/api/test_bulk_operations.py392 # Set state to cancelled
LOWtests/server/orchestration/api/test_flow_runs.py354 # Set limit to 50 bytes; even a small payload should fail
LOWtests/server/orchestration/api/test_deployments.py3789 # Set work_queue to None by removing the work_queue relationship
LOWtests/server/services/test_foreman.py462 # Set inactivity_heartbeat_multiple to 0 to immediately mark worker as offline
LOWtests/cli/test_deploy.py3699 # Check if the deployment was created correctly
LOWtests/cli/test_deploy.py3709 # Check if the second deployment was not created
LOWtests/cli/test_deploy.py3464 # Check if deployments were created correctly
LOWtests/cli/test_deploy.py3641 # Check if the two deployments were created correctly
LOWtests/cli/test_deploy.py3656 # Check if the third deployment was not created
LOWtests/cli/test_deploy.py3762 # Check if deployments were created correctly and without the provided CLI options
LOWtests/cli/test_deploy.py4034 # Check if the deployment was created correctly
LOWtests/cli/test_deploy.py4134 # Check if the deployment was created correctly
LOWtests/cli/test_deploy.py4195 # Check if the deployment was created correctly
LOWtests/cli/test_deploy.py4275 # Check if the deployment was created correctly
LOWtests/cli/test_deploy.py4366 # Check if the deployments were not created
LOWtests/cli/test_deploy.py4443 # Check if the deployment was created correctly
LOWtests/cli/test_deploy.py4570 # Check if the deployment was created correctly
LOWtests/cli/test_deploy.py4707 # Check if the deployment was created correctly
LOWtests/cli/test_deploy.py4754 # Check if the deployments were created correctly
LOWtests/cli/test_deploy.py6552 # Check if deployments were created correctly
LOWtests/utilities/test_hashing.py59 # Check if the hash is stable
LOW…/events/server/models/test_automation_notifications.py58 # Check if we're using PostgreSQL
LOW…infrastructure/provisioners/test_container_instance.py1326 None, # Assign identity to registry
LOW…infrastructure/provisioners/test_container_instance.py1634 None, # Assign identity to registry
LOW…infrastructure/provisioners/test_container_instance.py1973 None, # Assign identity to registry
LOW…infrastructure/provisioners/test_container_instance.py2322 None, # Assign identity to registry
LOWtests/infrastructure/provisioners/test_modal.py104 # Check if the block document exists and has expected values
LOWtests/infrastructure/provisioners/test_modal.py112 # Check if the base job template was updated
LOWtests/infrastructure/provisioners/test_modal.py149 # Check if the base job template was updated
LOWtests/infrastructure/provisioners/test_modal.py190 # Check if the block document exists and has expected values
LOWtests/infrastructure/provisioners/test_modal.py198 # Check if the base job template was updated
LOWtests/infrastructure/provisioners/test_coiled.py101 # Check if the block document exists and has expected values
LOWtests/infrastructure/provisioners/test_coiled.py108 # Check if the base job template was updated
LOWtests/infrastructure/provisioners/test_coiled.py131 # Check if the base job template was updated
LOWtests/infrastructure/provisioners/test_coiled.py170 # Check if the block document exists and has expected values
LOWtests/infrastructure/provisioners/test_coiled.py177 # Check if the base job template was updated
LOWtests/infrastructure/provisioners/test_ecs.py85 # Check if provisioning is needed
LOWtests/infrastructure/provisioners/test_ecs.py224 # Check if the IAM user exists
LOWtests/infrastructure/provisioners/test_ecs.py119 # Check if the IAM policy exists
LOWtests/infrastructure/provisioners/test_ecs.py330 # Check if the block document exists
LOWload_testing/run-server.sh13 # Check if container exists
LOWexamples/ai_data_analyst_with_pydantic_ai.py264 # Display results
LOWexamples/ai_data_analyst_with_pydantic_ai.py279 # Check if OpenAI API key is set
LOWscripts/backfill_release_notes.py223 # Check if we need to add spacing
LOWscripts/backfill_release_notes.py235 # Check if we need to add spacing
LOWscripts/prepare_release_notes.py231 # Check if we need to add spacing
LOWscripts/prepare_release_notes.py243 # Check if we need to add spacing
LOWscripts/prepare_integration_release_notes.py396 # Check if file exists to determine if we need frontmatter
LOWclient/client_deploy.py21 # Check if the smoke-test work pool exists
LOW…grations/prefect-dbt/prefect_dbt/core/_orchestrator.py868 # Check if any of the test's parents is node_id
LOWsrc/integrations/prefect-dbt/prefect_dbt/core/runner.py912 # Check if event has a message (cheap attribute access)
LOWsrc/integrations/prefect-dbt/prefect_dbt/core/runner.py1247 # Check if this is a valid dbt command
LOW…t_kubernetes_integration_tests/test_crash_detection.py78 # Check if we got at least the pending event - but only if we have events
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.
LOW…ions/prefect-kubernetes/prefect_kubernetes/observer.py707 # Check if there are any other jobs with this flow run label
LOW…ions/prefect-kubernetes/prefect_kubernetes/observer.py715 # Check if any other job is completed or running
69 more matches not shown…
Verbosity Indicators56 hits · 84 pts
SeverityFileLineSnippet
LOW…omations/automations-wizard/automation-wizard.test.tsx639 // Step 1: Trigger
LOW…omations/automations-wizard/automation-wizard.test.tsx645 // Step 2: Actions
LOW…omations/automations-wizard/automation-wizard.test.tsx655 // Step 3: Details
LOWexamples/resume_flow_run_on_pr_merge.py26# ## Step 1: Create a Prefect webhook
LOWexamples/resume_flow_run_on_pr_merge.py51# ## Step 2: Configure GitHub webhook
LOWexamples/resume_flow_run_on_pr_merge.py61# ## Step 3: Create an automation
LOWexamples/atproto_dashboard_with_prefect_assets.py67# ### Step 1: Fetch Raw Data
LOWexamples/atproto_dashboard_with_prefect_assets.py88# ### Step 2: Process the Data
LOWexamples/atproto_dashboard_with_prefect_assets.py116# ### Step 3: Create Analytics
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1264 # Step 1: full build — populate cache
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1267 # Step 2: change root SQL
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1270 # Step 3: selective run — only leaf
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1277 # Step 4: full build — root/mid rebuild, leaf must NOT cache-hit
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1283 # Step 1: all succeed
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1287 # Step 3: leaf re-executes (cache miss — upstream key changed)
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1290 # Step 4: root/mid re-execute (new file content); leaf must also
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1315 # Step 1: change root SQL
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1318 # Step 2: selective run — only leaf
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1325 # Step 3: selective run — only root and mid (rebuild upstream)
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1332 # Step 4: selective run — only leaf again
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1343 # Step 2: leaf executes (cache miss)
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1345 # Step 3: root and mid execute
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1348 # Step 4: leaf must re-execute (NOT cache-hit from step 2)
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1409 # Step 1: full build — populates execution state for all nodes
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1412 # Step 2: change A's SQL
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1415 # Step 3: selective run — only C
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1422 # Step 4: selective run — only D
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1433 # Step 1: all succeed
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1435 # Step 3: C executes (salted upstream keys since A changed)
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1437 # Step 4: D must re-execute, NOT cache-hit, because C was
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1515 # Step 1: full build — all succeed, execution state populated
LOW…ions/prefect-dbt/tests/core/test_orchestrator_cache.py1518 # Step 2: change mid's SQL so the cache key changes,
LOW…ntegrations/prefect-slack/prefect_slack/credentials.py107 # failures. This is not available in older versions, so we need to check if the
LOW…integrations/prefect-kubernetes/tests/test_observer.py877 # Step 1: Pod is Pending (no issues yet)
LOW…integrations/prefect-kubernetes/tests/test_observer.py911 # Step 2: Pod is still Pending but now has ImagePullBackOff
LOW…integrations/prefect-kubernetes/tests/test_observer.py982 # Step 1: Pod is Pending and Unschedulable
LOW…integrations/prefect-kubernetes/tests/test_observer.py1017 # Step 2: Pod transitions to Running (problem resolved)
LOW…integrations/prefect-kubernetes/tests/test_observer.py1072 # Step 1: CrashLoopBackOff
LOW…integrations/prefect-kubernetes/tests/test_observer.py1105 # Step 2: Pod terminates with OOMKilled
LOWsrc/integrations/prefect-redis/tests/test_ordering.py335 # Step 1: Follower parks itself
LOWsrc/integrations/prefect-redis/tests/test_ordering.py342 # Step 2: Leader completes, claiming the follower
LOWsrc/integrations/prefect-redis/tests/test_ordering.py350 # Step 3: Simulate follower's double-check path
LOWsrc/integrations/prefect-redis/tests/test_ordering.py362 # Step 4: Verify event data is STILL available for the leader
LOWsrc/prefect/runner/runner.py1644 # Step 1: client
LOWsrc/prefect/runner/runner.py1691 # Step 4: Construct client-dependent services after client is started
LOWsrc/prefect/runner/runner.py1742 # Step 5: runs_task_group
LOWsrc/prefect/runner/runner.py1797 # Step 6: Enter observer context manager last
LOWsrc/prefect/runner/_flow_run_executor.py132 # Step 2: already-cancelled precheck
LOWsrc/prefect/runner/_flow_run_executor.py164 # Step 6: remove handle from process_manager
LOWsrc/prefect/runner/_flow_run_executor.py168 # Step 7: interpret exit code and propose terminal state
LOWsrc/prefect/runner/_flow_run_executor.py184 # Step 8: run crashed hooks
LOWsrc/prefect/runner/_flow_run_executor.py247 # Step 1: client
LOWsrc/prefect/runner/_flow_run_executor.py267 # Step 2: ProcessManager with observer add/remove callbacks
LOWsrc/prefect/runner/_flow_run_executor.py278 # Step 3: StateProposer, placeholder HookRunner, EventEmitter
LOWsrc/prefect/runner/_flow_run_executor.py293 # Step 4: CancellationManager
LOWsrc/prefect/runner/_flow_run_executor.py303 # Step 5: Observer enters LAST (starts websocket/polling)
Over-Commented Block78 hits · 76 pts
SeverityFileLineSnippet
LOWtests/conftest.py41# fires a `UserWarning: The NumPy module was reloaded`, which our
LOWtests/events/server/triggers/test_flow_run_slas.py801
LOWdocs/.vale.ini21mdx = md
LOW…ork-pool-page-header/work-pool-page-header.stories.tsx101 },
LOW…ork-pool-page-header/work-pool-page-header.stories.tsx121// ...mockWorkPool,
LOWui-v2/src/hooks/use-debounce-callback.tsx61// type SearchProps {
LOWui-v2/src/hooks/use-debounce-callback.tsx81// />
LOWexamples/hello_world.py1# ---
LOWexamples/hello_world.py61 hello(name)
LOWexamples/hello_world.py81# For instance, change the greeting message in the `hello` function to a different message and run the flow again.
LOWexamples/hello_world.py101#
LOWexamples/ai_data_analyst_with_pydantic_ai.py1# ---
LOWexamples/ai_data_analyst_with_pydantic_ai.py21# 3. Uses Python tools to calculate statistics and detect anomalies
LOWexamples/ai_data_analyst_with_pydantic_ai.py281 print("❌ Error: OPENAI_API_KEY environment variable not set")
LOWexamples/ai_data_analyst_with_pydantic_ai.py301# ```bash
LOWexamples/ai_data_analyst_with_pydantic_ai.py321# - All operations respect 60s timeout
LOWexamples/ai_data_analyst_with_pydantic_ai.py341# 4. Trigger a run from the UI (http://localhost:4200) or CLI
LOWexamples/run_api_sourced_etl.py1# ---
LOWexamples/run_api_sourced_etl.py21# In this article you will:
LOWexamples/run_api_sourced_etl.py41#
LOWexamples/run_api_sourced_etl.py141# ## Run it!
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 t
LOWexamples/run_dbt_with_prefect.py1# ---
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]
LOWexamples/run_dbt_with_prefect.py41# ### Running the example locally
LOWexamples/run_dbt_with_prefect.py261#
LOWexamples/run_dbt_with_prefect.py281# - **Event-Driven**: Automatic Prefect events for dbt node status changes enable advanced monitoring and alerting
LOWexamples/resume_flow_run_on_pr_merge.py1# ---
LOWexamples/resume_flow_run_on_pr_merge.py21#
LOWexamples/resume_flow_run_on_pr_merge.py41# }
LOWexamples/resume_flow_run_on_pr_merge.py61# ## Step 3: Create an automation
LOWexamples/resume_flow_run_on_pr_merge.py101if __name__ == "__main__":
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 ev
LOWexamples/atproto_dashboard_with_prefect_assets.py1# ---
LOWexamples/atproto_dashboard_with_prefect_assets.py21# * **`@materialize` decorator** – Transform functions into versioned, cacheable data assets
LOWexamples/atproto_dashboard_with_prefect_assets.py41# # Follow README for setup and configuration
LOWexamples/atproto_dashboard_with_prefect_assets.py181
LOWexamples/atproto_dashboard_with_prefect_assets.py201# 3. **Storage Integration**
LOWexamples/atproto_dashboard_with_prefect_assets.py221# - dbt transformations with DuckDB
LOWexamples/ai_database_cleanup_with_approval.py1# ---
LOWexamples/ai_database_cleanup_with_approval.py21# [github.com/zzstoatzz/prefect-mcp-server-demo](https://github.com/zzstoatzz/prefect-mcp-server-demo)
LOWexamples/simple_web_scraper.py1# ---
LOWexamples/simple_web_scraper.py21#
LOWexamples/simple_web_scraper.py121# 2. Applied retry logic to the network call – a flaky connection would auto-retry up to 3 times.
LOWexamples/per_worker_task_concurrency.py1# ---
LOWexamples/per_worker_task_concurrency.py21# ## Example: Image processing with ML inference
LOWexamples/per_worker_task_concurrency.py121
LOWexamples/per_worker_task_concurrency.py141# prefect work-pool create ml-pool --type process
LOWexamples/per_worker_task_concurrency.py161#
LOWexamples/per_worker_task_concurrency.py181# 1. **GCLs are server-coordinated** — The Prefect server tracks who holds what
LOWscripts/wait-for-healthy-container.sh1#!/usr/bin/env bash
LOW.github/workflows/codeql-analysis.yml21 # │ ┌───────────── hour (0 - 23)
LOW.github/workflows/codspeed-benchmarks.yaml61 with:
LOW…egrations/prefect-dbt/prefect_dbt/cloud/credentials.py141 # "packageName": "tpch",
LOW…integrations/prefect-dask/prefect_dask/task_runners.py21 for number in range(highest_number):
LOW…efect-aws/prefect_aws/experimental/bundles/__init__.py1# Eagerly import the legacy submodules so that
LOW…c/integrations/prefect-ray/prefect_ray/task_runners.py21 for number in range(highest_number):
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,
LOW…c/integrations/prefect-redis/prefect_redis/ordering.py341
LOWsrc/prefect/context.py481 # Tracking for result from task runs and sub flows in this flow run for
18 more matches not shown…
AI Slop Vocabulary29 hits · 68 pts
SeverityFileLineSnippet
MEDIUMui/package-lock.json6217 "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.2.tgz",
MEDIUMui/package-lock.json11551 "resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.2.tgz",
MEDIUMtests/testing/test_utilites.py156 # Use test harness which starts background threads
MEDIUMtests/testing/test_utilites.py173 Regression test for issue #19342 - running the test harness multiple times
MEDIUMtests/testing/test_utilites.py186 # Run the test harness twice - the second run would fail with the bug
MEDIUMtests/public/flows/test_flow_crashes.py267 # this here, but we do not have robust testing utilities for deployed runs yet.
LOWtests/events/client/test_events_subscriber.py98 # The base subscriber for OSS will just use the API URL, which is set to a
LOWtests/logging/test_logs_subscriber.py127 # The base subscriber for OSS will just use the API URL, which is set to a
MEDIUMui-v2/src/routes/runs/index.tsx476 // Use useQuery for paginated flow runs to leverage placeholderData: keepPreviousData
MEDIUMui-v2/src/routes/runs/index.tsx482 // Use useQuery for paginated task runs to leverage placeholderData: keepPreviousData
MEDIUMui-v2/src/routes/runs/index.tsx487 // Use useQuery for flow run history (scatter plot) to leverage placeholderData: keepPreviousData
MEDIUMui-v2/src/routes/flows/index.tsx110 // Use useQuery for paginated flows to leverage placeholderData: keepPreviousData
MEDIUMui-v2/src/routes/flows/flow.$id.tsx335 // Use useQuery for deployments to leverage placeholderData: keepPreviousData
MEDIUMui-v2/src/routes/flows/flow.$id.tsx360 // Use useQuery for paginated flow runsto leverage placeholderData: keepPreviousData
MEDIUMexamples/run_dbt_with_prefect.py19# The result? Your analytics team gets reliable, observable data pipelines that leverage the strengths of both platforms
MEDIUMsrc/integrations/prefect-dbt/tests/core/test_tracker.py491 """Test a comprehensive workflow with multiple nodes and dependencies."""
LOW…grations/prefect-aws/prefect_aws/workers/ecs_worker.py1423 # Ensure the key is removed entirely, not just set to None
LOWsrc/integrations/prefect-azure/tests/test_aci_worker.py447 # If no entrypoint is provided, just use the command
LOWsrc/prefect/flow_engine.py2224 # parameters, in that case just return the parameters as-is.
LOWsrc/prefect/_internal/schemas/validators.py359 # rrule would just create different garbage. The real validator
MEDIUMsrc/prefect/_internal/concurrency/event_loop.py56 # result of the call. We wrap the call with a future to facilitate retrieval.
MEDIUMsrc/prefect/server/models/block_schemas.py658 # ones first (and to facilitate getting the newest one with `limit=1`).
LOWsrc/prefect/server/models/work_queues.py90 # work pool was created. We can just return it.
LOWsrc/prefect/_sdk/schema_converter.py93 # Handle allOf (intersection - we just use the first one with useful info)
MEDIUMsrc/prefect/_sdk/renderer.py435 # Use importlib.resources.files() for robust package resource access
LOWsrc/prefect/utilities/asyncutils/__init__.py402 # In a sync context and there is no event loop; just create an event loop
LOWsrc/prefect/utilities/templating/__init__.py174 # If there are no values, we can just use the template
MEDIUMsrc/prefect/testing/utilities.py170 # it after the harness exits, then register the harness server under
LOWsrc/prefect/bundles/_ignore_filter.py197 # Can't make relative - just use name
Fake / Example Data24 hits · 23 pts
SeverityFileLineSnippet
LOWtests/cli/test_work_pool.py742 "Hello world lorem ipsum",
LOWtests/cli/test_work_pool.py750 assert client_res.description == "Hello world lorem ipsum"
LOWui-v2/src/components/schemas/schema-form.test.tsx91 name: { type: "string", default: "John Doe" },
LOWui-v2/src/components/schemas/schema-form.test.tsx109 expect(spy).toHaveBeenCalledWith({ name: "John Doe" });
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. I
LOWui-v2/src/components/schemas/readme.md85 name: { type: "string", title: "Name", default: "John Doe" },
LOW…/src/components/schemas/stories/properties.stories.tsx80 default: "John Doe",
LOW…/src/components/schemas/stories/properties.stories.tsx588 name: "John Doe",
LOW…uns/flow-run-details-page/flow-run-details.stories.tsx25 display_value: "John Doe",
LOW…w-runs/flow-run-details-page/flow-run-details.test.tsx135 display_value: "John Doe",
LOW…w-runs/flow-run-details-page/flow-run-details.test.tsx145 expect(screen.getByText("John Doe")).toBeInTheDocument();
LOW…c/integrations/prefect-gcp/tests/test_cloud_storage.py270 "name": ["John Doe", "Jane Doe", "Johny", "Jane"],
LOW…c/integrations/prefect-gcp/tests/test_cloud_storage.py270 "name": ["John Doe", "Jane Doe", "Johny", "Jane"],
LOWsrc/integrations/prefect-aws/tests/test_utilities.py44 {"op": "add", "path": "/contact/address", "value": "123 Main St"},
LOWsrc/integrations/prefect-aws/prefect_aws/utilities.py89 {"op": "add", "path": "/contact/address", "value": "123 Main St"},
LOW…grations/prefect-databricks/prefect_databricks/jobs.py164 "base_parameters": {"name": "John Doe", "age": "35"},
LOW…grations/prefect-databricks/prefect_databricks/jobs.py663 "name": "John Doe",
LOW…grations/prefect-databricks/prefect_databricks/jobs.py1608 "base_parameters": {"name": "John Doe", "age": "35"},
LOW…grations/prefect-databricks/prefect_databricks/jobs.py1845 "name": "John Doe",
LOW…rations/prefect-databricks/prefect_databricks/flows.py129 "base_parameters": {"name": "John Doe", "age": "35"},
LOW…s/prefect-databricks/prefect_databricks/models/jobs.py862 examples=[{"age": 35, "name": "John Doe"}],
LOW…s/prefect-databricks/prefect_databricks/models/jobs.py2535 examples=[{"age": 35, "name": "John Doe"}],
LOW…s/prefect-databricks/prefect_databricks/models/jobs.py3913 "base_parameters": {"age": "35", "name": "John Doe"},
LOW…s/prefect-databricks/prefect_databricks/models/jobs.py4342 "base_parameters": {"age": "35", "name": "John Doe"},
Overly Generic Function Names20 hits · 19 pts
SeverityFileLineSnippet
LOWtests/blocks/test_core.py1706 def do_stuff(self, thing: str):
LOWtests/_internal/compatibility/test_async_dispatch.py23 def my_function() -> None:
LOWtests/_internal/compatibility/test_async_dispatch.py36 def my_function() -> None:
LOWtests/_internal/compatibility/test_async_dispatch.py50 def my_function() -> None:
LOWtests/_internal/compatibility/test_async_dispatch.py73 def my_method(cls) -> str:
LOWtests/_internal/compatibility/test_async_dispatch.py90 def my_method(cls) -> str:
LOWtests/_internal/compatibility/test_async_dispatch.py106 def my_function() -> None:
LOWtests/_internal/compatibility/test_async_dispatch.py118 def my_function() -> None:
LOWtests/_internal/compatibility/test_async_dispatch.py234 def my_function() -> str:
LOWtests/_internal/compatibility/test_async_dispatch.py255 def my_function() -> str:
LOWtests/_internal/compatibility/test_async_dispatch.py276 def my_function() -> str:
LOWtests/_internal/compatibility/test_async_dispatch.py297 def my_function() -> str:
LOWtests/_internal/pydantic/test_validated_func.py506 def process_data(model: MyModel, count: int = 0) -> dict:
LOWtests/telemetry/test_run_telemetry.py52async def run_task(task, task_run_id, parameters, engine_type):
LOWui-v2/public/mockServiceWorker.js122async function handleRequest(event, requestId) {
LOWexamples/atproto_dashboard_with_prefect_assets.py97def process_data(raw_data: dict[str, Any]) -> dict[str, Any]:
LOW…/integrations/prefect-dbt/prefect_dbt/core/_tracker.py145 def run_task():
LOWsrc/prefect/task_engine.py1842def run_task(
LOWsrc/prefect/task_engine.py1855def run_task(
LOWsrc/prefect/task_engine.py1867def run_task(
Synthetic Comment Markers2 hits · 10 pts
SeverityFileLineSnippet
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 AG
HIGH.github/workflows/docs-update.yml151 This PR was generated by Claude Code analyzing source code changes and updating any stale documentation.
Magic Placeholder Names1 hit · 5 pts
SeverityFileLineSnippet
HIGHsrc/integrations/prefect-aws/README.md200 -e PREFECT_API_KEY=your-api-key \