Repository Analysis

dagster-io/dagster

An orchestration platform for the development, production, and observation of data assets.

15.2 Moderate AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of dagster-io/dagster, a Python project with 15,921 GitHub stars. SynthScan v2.0 examined 1,519,834 lines of code across 10725 source files, recording 20852 pattern matches distributed across 27 syntactic categories. The overall adjusted score of 15.2 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).

15.2
Adjusted Score
15.2
Raw Score
100%
Time Factor
2026-07-31
Last Push
15.9K
Stars
Python
Language
1.5M
Lines of Code
10.7K
Files
20.9K
Pattern Hits
2026-08-02
Scan Date
0.04
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 10HIGH 399MEDIUM 526LOW 19917

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 20852 distinct pattern matches across 27 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 Identifiers13501 hits · 13041 pts
SeverityFileLineSnippetContext
LOWRUN_API_IMPLEMENTATION_PLAN.md257def get_run_events_via_graphql(CODE
LOWMIGRATION.md629def my_metadata_from_dbt_resource_props(dbt_resource_props):CODE
LOW…on_modules/dagster-test/dagster_test/toys/freshness.py22def asset_with_time_window_freshness_and_warning():CODE
LOW…on_modules/dagster-test/dagster_test/toys/freshness.py31def asset_with_time_window_freshness_fast_fail():CODE
LOW…on_modules/dagster-test/dagster_test/toys/freshness.py41def asset_with_cron_freshness_policy():CODE
LOW…on_modules/dagster-test/dagster_test/toys/freshness.py52def asset_with_cron_freshness_policy_with_timezone():CODE
LOW…on_modules/dagster-test/dagster_test/toys/freshness.py62def asset_with_cron_freshness_policy_short_cron_interval():CODE
LOW…on_modules/dagster-test/dagster_test/toys/freshness.py73def asset_with_cron_freshness_policy_irregular_schedule():CODE
LOW…thon_modules/dagster-test/dagster_test/toys/sensors.py101 def custom_slack_on_job_failure(context: RunFailureSensorContext):CODE
LOW…odules/dagster-test/dagster_test/toys/error_monster.py67def define_errorable_resource():CODE
LOW…odules/dagster-test/dagster_test/toys/data_versions.py15def observable_different_version():CODE
LOW…odules/dagster-test/dagster_test/toys/data_versions.py43def has_code_version_multiple_deps(): ...CODE
LOW…odules/dagster-test/dagster_test/toys/data_versions.py47def downstream_of_code_versioned(): ...CODE
LOW…odules/dagster-test/dagster_test/toys/data_versions.py51def root_asset_no_code_version(context):CODE
LOW…odules/dagster-test/dagster_test/toys/data_versions.py56def downstream_of_no_code_version(): ...CODE
LOW…odules/dagster-test/dagster_test/toys/data_versions.py66def code_versioned_multi_asset():CODE
LOW…odules/dagster-test/dagster_test/toys/data_versions.py72def downstream_of_code_versioned_multi_asset(): ...CODE
LOW…modules/dagster-test/dagster_test/toys/asset_checks.py98def asset_with_check_in_same_op():CODE
LOW…modules/dagster-test/dagster_test/toys/asset_checks.py144def random_fail_check_on_partitioned_asset():CODE
LOW…modules/dagster-test/dagster_test/toys/asset_checks.py222def stage_then_promote_graph_asset():CODE
LOW…modules/dagster-test/dagster_test/toys/asset_checks.py267def promote_staged_asset_with_tests(staged_asset):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_checks.py390def many_tests_graph_multi_asset():CODE
LOW…_modules/dagster-test/dagster_test/toys/many_events.py76def many_table_materializations(_context):CODE
LOW…_modules/dagster-test/dagster_test/toys/many_events.py103def many_materializations_and_passing_expectations(_context):CODE
LOW…_modules/dagster-test/dagster_test/toys/many_events.py134def check_users_and_groups_one_fails_one_succeeds(_context):CODE
LOW…_modules/dagster-test/dagster_test/toys/many_events.py169def check_admins_both_succeed(_context):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py48def downstream_of_always_fails(always_fails):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py80def random_failure_partitioned_asset(context):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py128def always_materializes_check_sometimes_warns(context):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py136def always_materializes_check_sometimes_errors(context):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py144def observable_source_asset_always_observes():CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py149def observable_source_asset_execution_error():CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py154def observable_source_asset_random_execution_error(context):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py166def asset_with_freshness_and_warning():CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py179def insert_source_asset_materializations(context: dg.OpExecutionContext) -> None:CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py184def insert_source_asset_materializations_job() -> None:CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py190def observe_no_def_observable(context):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py195def observe_no_def_observable_job():CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py200def materialize_no_def_materializable(context):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py219def checks_no_def_materializable(context):CODE
LOW…modules/dagster-test/dagster_test/toys/asset_health.py230def materialize_no_def_materializable_job():CODE
LOW…ules/dagster-test/dagster_test/toys/external_assets.py19def insert_materializations_job() -> None:CODE
LOW…les/dagster-test/dagster_test/toys/partition_config.py15def job_with_partition_config():CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py162def partitioned_assets_repository():CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py182def table_metadata_repository():CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py189def long_asset_keys_repository():CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py196def big_honkin_assets_repository():CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py205def upstream_assets_repository():CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py220def graph_backed_asset_repository():CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py225def assets_with_sensors_repository():CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py230def conditional_assets_repository():CODE
LOW…er-test/dagster_test/toys/seed_asset_failure_events.py154def seed_asset_failure_events():CODE
LOW…les/dagster-test/dagster_test/toys/freshness_checks.py87def get_last_updated_timestamp_unreliable_source() -> TimestampMetadataValue:CODE
LOW…on_modules/dagster-test/dagster_test/toys/notebooks.py19def hello_world_notebook_pipeline():CODE
LOW…s/dagster-test/dagster_test/toys/run_status_sensors.py48def yield_run_request_succeeds_sensor(context):CODE
LOW…s/dagster-test/dagster_test/toys/run_status_sensors.py66def return_run_request_succeeds_sensor(context):CODE
LOW…s/dagster-test/dagster_test/toys/run_status_sensors.py99def success_sensor_with_pipeline_run_reaction(context):CODE
LOW…s/dagster-test/dagster_test/toys/run_status_sensors.py105def yield_multi_run_request_success_sensor(context):CODE
LOW…s/dagster-test/dagster_test/toys/run_status_sensors.py125def return_multi_run_request_success_sensor(context):CODE
LOW…s/dagster-test/dagster_test/toys/run_status_sensors.py206def cross_repo_success_job_sensor(context):CODE
13441 more matches not shown…
Unused Imports3431 hits · 2903 pts
SeverityFileLineSnippetContext
LOWpython_modules/dagster-test/dagster_test/toys/repo.py24CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py24CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py28CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py31CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py83CODE
LOWpython_modules/dagster-test/dagster_test/toys/repo.py85CODE
LOW…-test/dagster_test/toys/partitioned_assets/__init__.py1CODE
LOW…-test/dagster_test/toys/partitioned_assets/__init__.py2CODE
LOW…-test/dagster_test/toys/partitioned_assets/__init__.py3CODE
LOW…-test/dagster_test/toys/partitioned_assets/__init__.py4CODE
LOW…-test/dagster_test/toys/partitioned_assets/__init__.py5CODE
LOW…-test/dagster_test/toys/partitioned_assets/__init__.py6CODE
LOW…-test/dagster_test/toys/partitioned_assets/__init__.py7CODE
LOW…-test/dagster_test/toys/partitioned_assets/__init__.py8CODE
LOW…gster-test/dagster_test/toys/column_schema/__init__.py1CODE
LOW…t/dagster_test/utils/definitions_execute_in_process.py14CODE
LOW…t/dagster_test/utils/definitions_execute_in_process.py15CODE
LOW…dules/dagster-test/dagster_test/components/__init__.py1CODE
LOW…dules/dagster-test/dagster_test/components/__init__.py4CODE
LOW…dules/dagster-test/dagster_test/components/__init__.py7CODE
LOW…dules/dagster-test/dagster_test/components/__init__.py8CODE
LOW…on_modules/dagster-graphql/dagster_graphql/__init__.py3CODE
LOW…on_modules/dagster-graphql/dagster_graphql/__init__.py3CODE
LOW…on_modules/dagster-graphql/dagster_graphql/__init__.py3CODE
LOW…on_modules/dagster-graphql/dagster_graphql/__init__.py3CODE
LOW…on_modules/dagster-graphql/dagster_graphql/__init__.py3CODE
LOW…on_modules/dagster-graphql/dagster_graphql/__init__.py3CODE
LOW…on_modules/dagster-graphql/dagster_graphql/__init__.py3CODE
LOW…les/dagster-graphql/dagster_graphql/schema/instance.py23CODE
LOW…/dagster-graphql/dagster_graphql/schema/asset_graph.py87CODE
LOW…/dagster-graphql/dagster_graphql/schema/asset_graph.py87CODE
LOW…/dagster-graphql/dagster_graphql/schema/asset_graph.py87CODE
LOW…/dagster-graphql/dagster_graphql/schema/asset_graph.py124CODE
LOW…/dagster-graphql/dagster_graphql/schema/asset_graph.py124CODE
LOW…/dagster-graphql/dagster_graphql/schema/asset_graph.py124CODE
LOW…ter-graphql/dagster_graphql/schema/schedule_dry_run.py22CODE
LOW…agster-graphql/dagster_graphql/schema/dagster_types.py23CODE
LOW…dagster-graphql/dagster_graphql/schema/asset_checks.py8CODE
LOW…les/dagster-graphql/dagster_graphql/schema/backfill.py64CODE
LOW…gster-graphql/dagster_graphql/schema/partition_sets.py7CODE
LOW…gster-graphql/dagster_graphql/schema/partition_sets.py56CODE
LOW…gster-graphql/dagster_graphql/schema/sensor_dry_run.py22CODE
LOW…odules/dagster-graphql/dagster_graphql/schema/table.py12CODE
LOW…/dagster-graphql/dagster_graphql/schema/roots/query.py1CODE
LOW…/dagster-graphql/dagster_graphql/schema/logs/events.py27CODE
LOW…l/dagster_graphql/implementation/fetch_asset_checks.py46CODE
LOW…gster-graphql/dagster_graphql/implementation/events.py34CODE
LOW…gster-graphql/dagster_graphql/implementation/events.py34CODE
LOW…gster-graphql/dagster_graphql/implementation/events.py34CODE
LOW…gster-graphql/dagster_graphql/implementation/events.py44CODE
LOW…gster-graphql/dagster_graphql/implementation/events.py47CODE
LOW…gster-graphql/dagster_graphql/implementation/events.py48CODE
LOW…r-graphql/dagster_graphql/implementation/fetch_runs.py37CODE
LOW…ementation/fetch_auto_materialize_asset_evaluations.py15CODE
LOW…er-graphql/dagster_graphql/implementation/telemetry.py9CODE
LOW…ql/dagster_graphql/implementation/fetch_instigators.py16CODE
LOW…graphql/implementation/fetch_app_managed_components.py20CODE
LOW…graphql/implementation/fetch_app_managed_components.py21CODE
LOW…graphql/implementation/fetch_app_managed_components.py22CODE
LOW…graphql/implementation/fetch_app_managed_components.py35CODE
3371 more matches not shown…
Structural Annotation Overuse707 hits · 1138 pts
SeverityFileLineSnippetContext
LOW…hon_modules/libraries/dagster-rest-resources/README.md49### Step 1: Define/Update QueriesCOMMENT
LOW…hon_modules/libraries/dagster-rest-resources/README.md76### Step 2: Generate CodeCOMMENT
LOW…hon_modules/libraries/dagster-rest-resources/README.md87### Step 3: Define SchemaCOMMENT
LOW…hon_modules/libraries/dagster-rest-resources/README.md110### Step 4: Create API Class and Unit TestsCOMMENT
LOW…ter-rest-resources/dagster_rest_resources/s3_client.py14 # Step 1: Get presigned POST URLCOMMENT
LOW…ter-rest-resources/dagster_rest_resources/s3_client.py23 # Step 2: Upload file to S3 via presigned POSTCOMMENT
LOW…ter-rest-resources/dagster_rest_resources/s3_client.py33 # Step 1: Get presigned GET URLCOMMENT
LOW…ter-rest-resources/dagster_rest_resources/s3_client.py42 # Step 2: Download file from S3COMMENT
LOW…libraries/dagster-omni/dagster_omni_tests/test_defs.py240 # Step 1: Fetch workspace data from "API"COMMENT
LOW…libraries/dagster-omni/dagster_omni_tests/test_defs.py246 # Step 2: Build definitions from workspace dataCOMMENT
LOW…dagster-polytomic/dagster_polytomic_tests/test_defs.py279 # Step 1: Fetch workspace data from "API"COMMENT
LOW…dagster-polytomic/dagster_polytomic_tests/test_defs.py282 # Step 2: Build definitions from workspace dataCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py425 # Step 1: Start with versioned storage, no state availableCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py449 # Step 2: Run the update state job to populate versioned storageCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py453 # Step 3: Reload with versioned storage - should have updated valueCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py464 # Step 4: Switch to local storage - should reset to initial valueCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py488 # Step 5: Load with DAGSTER_IS_DEV_CLI set - should force local refreshCOMMENT
LOW…ons/declarative_automation/operators/since_operator.py139 # Step 1: Add all newly-true trigger partitionsCOMMENT
LOW…ons/declarative_automation/operators/since_operator.py142 # Step 2: Remove all newly-true reset partitionsCOMMENT
LOW…ons/declarative_automation/operators/since_operator.py145 # Step 3: Use TimingMetadata to re-add partitions where trigger fired after resetCOMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py781 # Step 3: Agent is stuck - actual == desired but _grpc_servers has an errorCOMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py786 # Step 4: Next workspace query - server reports no error (hasLoadError=False).COMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py799 # Step 5: Location should be healthy againCOMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py735 # Step 1: Deploy successfullyCOMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py749 # Step 2: _refresh_actual_entries detects server moved to error state.COMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py200 # Step 0: Auto-prepare if requestedCOMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py204 # Step 1: Verify PR exists (skip if we have context)COMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py212 # Step 2: Update PR titleCOMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py217 # Step 3: Update PR bodyCOMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py222 # Step 4: Update commit messageCOMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py232 # Step 5: Display success and Graphite URLCOMMENT
LOW.claude/agents/pr-update-expert.md41### Step 1: Repository Context GatheringCOMMENT
LOW.claude/agents/pr-update-expert.md54### Step 2: Thesis Collection StrategyCOMMENT
LOW.claude/agents/pr-update-expert.md68### Step 3: AI Analysis GenerationCOMMENT
LOW.claude/agents/pr-update-expert.md95### Step 4: Atomic PR UpdateCOMMENT
LOW.claude/commands/enforce_standards.md3## Step 0: Stack Preparation with Merge Conflict DetectionCOMMENT
LOW.claude/commands/enforce_standards.md20## Step 1: Invoke Code Standards Enforcer AgentCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md15### Step 1: Detect Current Branch PRCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md22### Step 2: Fetch All PR CommentsCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md28### Step 3: Identify Diamond CommentsCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md38### Step 4: Analyze Diamond FeedbackCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md49### Step 5: Create Action PlanCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md59### Step 6: Present Comments for ReviewCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md69### Step 7: Validate Comment RelevanceCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md78### Step 8: Mark Comments as ResolvedCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md98### Step 9: Generate Final Action PlanCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md104### Step 10: Present Final Plan and ConfirmCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md167# Step 1: Get Diamond review thread IDs for resolving conversationsCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md193# Step 2: Filter for UNRESOLVED Diamond threads and extract thread IDsCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md201# Step 3: Resolve specific Diamond review thread conversationsCOMMENT
LOW.claude/commands/analyze_diamond_feedback.md213# Step 4: Batch resolve multiple Diamond threadsCOMMENT
LOW.claude/commands/erk/learn.md31### Step 1: Get Session InformationCOMMENT
LOW.claude/commands/erk/learn.md48### Step 2: Analyze ImplementationCOMMENT
LOW.claude/commands/erk/learn.md97### Step 3: Gather and Analyze SessionsCOMMENT
LOW.claude/commands/erk/learn.md198### Step 4: Identify Documentation GapsCOMMENT
LOW.claude/commands/erk/learn.md336### Step 5: Present FindingsCOMMENT
LOW.claude/commands/erk/learn.md350### Step 6: Create Plan IssueCOMMENT
LOW.claude/commands/erk/learn.md395### Step 7: Track EvaluationCOMMENT
LOW.claude/commands/erk/plan-implement.md38### Step 0: Parse ArgumentsCOMMENT
LOW.claude/commands/erk/plan-implement.md49### Step 1: Determine Implementation SourceCOMMENT
647 more matches not shown…
Deep Nesting816 hits · 760 pts
SeverityFileLineSnippetContext
LOW…hon_modules/dagster-test/dagster_test/toys/log_spew.py6CODE
LOW…hon_modules/dagster-test/dagster_test/toys/log_spew.py17CODE
LOW…st/dagster_test/toys/auto_materializing/large_graph.py33CODE
LOW…on_modules/dagster-test/dagster_test/dg_utils/utils.py301CODE
LOW…on_modules/dagster-test/dagster_test/dg_utils/utils.py361CODE
LOW…gster-test/dagster_test/test_project/test_jobs/repo.py88CODE
LOW…dagster-graphql/dagster_graphql/schema/config_types.py24CODE
LOW…gster-graphql/dagster_graphql/schema/partition_sets.py508CODE
LOW…gster-graphql/dagster_graphql/schema/partition_sets.py520CODE
LOW…ter-graphql/dagster_graphql/schema/pipelines/config.py95CODE
LOW…ter-graphql/dagster_graphql/schema/pipelines/config.py144CODE
LOW…ter-graphql/dagster_graphql/schema/pipelines/status.py22CODE
LOW…-graphql/dagster_graphql/schema/schedules/schedules.py141CODE
LOW…gster-graphql/dagster_graphql/schema/logs/log_level.py18CODE
LOW…gster-graphql/dagster_graphql/implementation/events.py54CODE
LOW…gster-graphql/dagster_graphql/implementation/events.py234CODE
LOW…graphql/dagster_graphql/implementation/fetch_assets.py440CODE
LOW…agster-graphql/dagster_graphql/implementation/utils.py430CODE
LOW…gster-graphql/dagster_graphql/implementation/loader.py57CODE
LOW…gster_graphql/implementation/partition_status_utils.py140CODE
LOW…-graphql/dagster_graphql/implementation/fetch_ticks.py14CODE
LOW…l/dagster_graphql/implementation/execution/backfill.py92CODE
LOW…dules/dagster-graphql/dagster_graphql/client/client.py151CODE
LOW…hql_tests/graphql/test_definition_owner_permissions.py966CODE
LOW…hql_tests/graphql/test_definition_owner_permissions.py991CODE
LOW…-graphql/dagster_graphql_tests/graphql/test_context.py34CODE
LOW…lient_backcompat/test_backcompat_with_python_client.py15CODE
LOW…es/dagster-airbyte/dagster_airbyte/legacy_resources.py172CODE
LOW…es/dagster-airbyte/dagster_airbyte/legacy_resources.py555CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py61CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py186CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py256CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py420CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py230CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py363CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py524CODE
LOW…libraries/dagster-airbyte/dagster_airbyte/resources.py376CODE
LOW…ster-airbyte/dagster_airbyte/managed/reconciliation.py155CODE
LOW…ster-airbyte/dagster_airbyte/managed/reconciliation.py242CODE
LOW…agster-airbyte/dagster_airbyte_tests/test_resources.py80CODE
LOW…irbyte/dagster_airbyte_tests/test_generated_classes.py26CODE
LOW…-airbyte/dagster_airbyte_tests/test_cloud_resources.py60CODE
LOW…ter_airbyte_tests/integration/test_managed_elements.py47CODE
LOW…es/libraries/create-dagster/create_dagster/scaffold.py102CODE
LOW…ibraries/create-dagster/create_dagster/cli/scaffold.py71CODE
LOW…n_modules/libraries/dagster-dask/dagster_dask/utils.py188CODE
LOW…odules/libraries/dagster-dask/dagster_dask/executor.py168CODE
LOW…aries/dagster-snowflake/dagster_snowflake/resources.py701CODE
LOW…aries/dagster-snowflake/dagster_snowflake/resources.py746CODE
LOW…aries/dagster-snowflake/dagster_snowflake/resources.py786CODE
LOW…aries/dagster-snowflake/dagster_snowflake/resources.py827CODE
LOW…aries/dagster-snowflake/dagster_snowflake/resources.py967CODE
LOW…/dagster_snowflake/components/dbt_project/component.py786CODE
LOW…/dagster_snowflake/components/dbt_project/component.py879CODE
LOW…/dagster_snowflake/components/dbt_project/component.py1016CODE
LOW…/dagster_snowflake/components/dbt_project/component.py1049CODE
LOW…/dagster-snowflake/dagster_snowflake_tests/conftest.py24CODE
LOW…es/dagster-cloud-cli/dagster_cloud_cli/config_utils.py440CODE
LOW…ter-cloud-cli/dagster_cloud_cli/core/graphql_client.py142CODE
LOW…r-cloud-cli/dagster_cloud_cli/core/pex_builder/deps.py100CODE
756 more matches not shown…
Cross-File Repetition148 hits · 740 pts
SeverityFileLineSnippetContext
HIGH…ules/dagster-graphql/dagster_graphql/schema/sensors.py0enable a schedule to launch runs for a job based on external state change.STRING
HIGH…gster-graphql/dagster_graphql/schema/sensor_dry_run.py0enable a schedule to launch runs for a job based on external state change.STRING
HIGH…ter-graphql/dagster_graphql/schema/schedule_dry_run.py0enable a schedule to launch runs for a job based on external state change.STRING
HIGH…er-snowflake/dagster_snowflake/snowflake_io_manager.py0returns a sql statement that deletes data in the given table to make way for the output data being written.STRING
HIGH…/libraries/dagster-duckdb/dagster_duckdb/io_manager.py0returns a sql statement that deletes data in the given table to make way for the output data being written.STRING
HIGH…braries/dagster-gcp/dagster_gcp/bigquery/io_manager.py0returns a sql statement that deletes data in the given table to make way for the output data being written.STRING
HIGH…oject_fully_featured/resources/snowflake_io_manager.py0returns a sql statement that deletes data in the given table to make way for the output data being written.STRING
HIGH…er-snowflake/dagster_snowflake/snowflake_io_manager.py0{table_partition.partition_expr} >= '{start_dt_str}' and {table_partition.partition_expr} < '{end_dt_str}'STRING
HIGH…ries/dagster-deltalake/dagster_deltalake/io_manager.py0{table_partition.partition_expr} >= '{start_dt_str}' and {table_partition.partition_expr} < '{end_dt_str}'STRING
HIGH…/libraries/dagster-duckdb/dagster_duckdb/io_manager.py0{table_partition.partition_expr} >= '{start_dt_str}' and {table_partition.partition_expr} < '{end_dt_str}'STRING
HIGH…braries/dagster-gcp/dagster_gcp/bigquery/io_manager.py0{table_partition.partition_expr} >= '{start_dt_str}' and {table_partition.partition_expr} < '{end_dt_str}'STRING
HIGH…s/libraries/dagster-cloud-cli/dagster_cloud_cli/gql.py0query clideploymentsquery { fulldeployments { deploymentname deploymentid deploymenttype } }STRING
HIGH…raries/dagster-dg-cli/dagster_dg_cli/utils/plus/gql.py0query clideploymentsquery { fulldeployments { deploymentname deploymentid deploymenttype } }STRING
HIGH…gster-dg-cli/dagster_dg_cli/cli/plus/GRAPHQL_SCHEMA.md0query clideploymentsquery { fulldeployments { deploymentname deploymentid deploymenttype } }STRING
HIGH…ibraries/dagster-dlt/dagster_dlt/dlt_event_iterator.py0a wrapper around an iterator of sling events which contains additional methods for post-processing the events, such as fSTRING
HIGH…r-fivetran/dagster_fivetran/fivetran_event_iterator.py0a wrapper around an iterator of sling events which contains additional methods for post-processing the events, such as fSTRING
HIGH…es/dagster-sling/dagster_sling/sling_event_iterator.py0a wrapper around an iterator of sling events which contains additional methods for post-processing the events, such as fSTRING
HIGH…/dagster_postgres/schedule_storage/schedule_storage.py0postgres-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery STRING
HIGH…gster-postgres/dagster_postgres/event_log/event_log.py0postgres-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery STRING
HIGH…r-postgres/dagster_postgres/run_storage/run_storage.py0postgres-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery STRING
HIGH…gster-postgres/dagster_postgres/event_log/event_log.py0store an event corresponding to a pipeline run. args: event (eventlogentry): the event to store.STRING
HIGH…gster/dagster/_core/storage/event_log/sql_event_log.py0store an event corresponding to a pipeline run. args: event (eventlogentry): the event to store.STRING
HIGH…odules/dagster/dagster/_core/storage/event_log/base.py0store an event corresponding to a pipeline run. args: event (eventlogentry): the event to store.STRING
HIGHpython_modules/libraries/dagster-k8s/dagster_k8s/job.py0set this value if you are running the launcher within a k8s cluster. if ``true``, we assume the launcher is running withSTRING
HIGH…es/libraries/dagster-k8s/dagster_k8s/ops/k8s_job_op.py0set this value if you are running the launcher within a k8s cluster. if ``true``, we assume the launcher is running withSTRING
HIGH…raries/dagster-celery-k8s/dagster_celery_k8s/config.py0set this value if you are running the launcher within a k8s cluster. if ``true``, we assume the launcher is running withSTRING
HIGH…s/dagster-k8s/dagster_k8s_tests/unit_tests/conftest.py0apiversion: v1 kind: config current-context: fake-context contexts: - context: cluster: fake-cluster name: fake-context STRING
HIGH…agster-celery-k8s/dagster_celery_k8s_tests/conftest.py0apiversion: v1 kind: config current-context: fake-context contexts: - context: cluster: fake-cluster name: fake-context STRING
HIGH…loud_tests/workspace_tests/test_kubernetes_launcher.py0apiversion: v1 kind: config current-context: fake-context contexts: - context: cluster: fake-cluster name: fake-context STRING
HIGH…s/dagster-k8s/dagster_k8s_tests/unit_tests/conftest.py0returns a str file path for a minimal kubeconfig file in the default location (~/.kube/config).STRING
HIGH…agster-celery-k8s/dagster_celery_k8s_tests/conftest.py0returns a str file path for a minimal kubeconfig file in the default location (~/.kube/config).STRING
HIGH…loud_tests/workspace_tests/test_kubernetes_launcher.py0returns a str file path for a minimal kubeconfig file in the default location (~/.kube/config).STRING
HIGH…/libraries/dagster-census/dagster_census/translator.py0a record representing all content in a tableau workspace. provided as context for the translator so that it can resolve STRING
HIGH…ibraries/dagster-powerbi/dagster_powerbi/translator.py0a record representing all content in a tableau workspace. provided as context for the translator so that it can resolve STRING
HIGH…raries/dagster-fivetran/dagster_fivetran/translator.py0a record representing all content in a tableau workspace. provided as context for the translator so that it can resolve STRING
HIGH…ibraries/dagster-tableau/dagster_tableau/translator.py0a record representing all content in a tableau workspace. provided as context for the translator so that it can resolve STRING
HIGH…itchen_sink_tests/integration_tests/test_e2e_mapped.py0test that assets can load properly, and that materializations register.STRING
HIGH…er-airlift/perf-harness/perf_harness_tests/test_e2e.py0test that assets can load properly, and that materializations register.STRING
HIGH…/dbt_example_tests/integration_tests/test_federated.py0test that assets can load properly, and that materializations register.STRING
HIGH…ample_tests/integration_tests/test_migration_stages.py0test that assets can load properly, and that materializations register.STRING
HIGH…ter_powerbi/components/power_bi_workspace/component.py0the tableau translation schema supports defining global transforms as well as per-content-type transforms. this resolverSTRING
HIGH…ster-sigma/dagster_sigma/components/sigma_component.py0the tableau translation schema supports defining global transforms as well as per-content-type transforms. this resolverSTRING
HIGH…er-looker/dagster_looker/api/components/translation.py0the tableau translation schema supports defining global transforms as well as per-content-type transforms. this resolverSTRING
HIGH…ster-tableau/dagster_tableau/components/translation.py0the tableau translation schema supports defining global transforms as well as per-content-type transforms. this resolverSTRING
HIGH…ter-gcp/dagster_gcp/dataproc/types_dataproc_cluster.py0note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \STRING
HIGH…dagster-gcp/dagster_gcp/dataproc/types_dataproc_job.py0note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \STRING
HIGH…r-gcp/dagster_gcp/dataproc/configs_dataproc_cluster.py0note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \STRING
HIGH…gster-gcp/dagster_gcp/dataproc/configs_dataproc_job.py0note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \STRING
HIGH…libraries/dagster-aws/dagster_aws/emr/configs_spark.py0note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \STRING
HIGH…libraries/dagster-spark/dagster_spark/configs_spark.py0note: this file is auto-generated. do not edit. @generated produced via: parse_spark_configs.py \STRING
HIGH…as/dagster_duckdb_pandas/duckdb_pandas_type_handler.py0an i/o manager definition that reads inputs from and writes polars dataframes to duckdb. when using the duckdbpolarsiomaSTRING
HIGH…/dagster_duckdb_pyspark/duckdb_pyspark_type_handler.py0an i/o manager definition that reads inputs from and writes polars dataframes to duckdb. when using the duckdbpolarsiomaSTRING
HIGH…rs/dagster_duckdb_polars/duckdb_polars_type_handler.py0an i/o manager definition that reads inputs from and writes polars dataframes to duckdb. when using the duckdbpolarsiomaSTRING
HIGH…sql/dagster_mysql/schedule_storage/schedule_storage.py0mysql-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery wheSTRING
HIGH…ies/dagster-mysql/dagster_mysql/event_log/event_log.py0mysql-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery wheSTRING
HIGH…dagster-mysql/dagster_mysql/run_storage/run_storage.py0mysql-backed run storage. users should not directly instantiate this class; it is instantiated by internal machinery wheSTRING
HIGH…sts/api_tests/asset_check_tests/test_business_logic.py0test alert policy business logic functions without mocks. these tests focus on testing pure functions that process data STRING
HIGH…li_tests/api_tests/sensor_tests/test_business_logic.py0test alert policy business logic functions without mocks. these tests focus on testing pure functions that process data STRING
HIGH…ts/api_tests/alert_policy_tests/test_business_logic.py0test alert policy business logic functions without mocks. these tests focus on testing pure functions that process data STRING
HIGH…li_tests/api_tests/secret_tests/test_business_logic.py0test alert policy business logic functions without mocks. these tests focus on testing pure functions that process data STRING
88 more matches not shown…
Cross-Language Confusion118 hits · 692 pts
SeverityFileLineSnippetContext
HIGH…e/dagster_deltalake_tests/test_delta_table_resource.py30 assert res.equals(data)CODE
HIGH…e/dagster_deltalake_tests/test_delta_table_resource.py67 assert res.equals(data)CODE
HIGH…s/dagster-duckdb/dagster_duckdb_tests/test_resource.py23 assert res.equals(sample_df)CODE
HIGH…er-dbt/dagster_dbt/components/dbt_project/component.py91 This component assumes that you have already set up a dbt project, for example, the dbt `Jaffle shop <https://githubSTRING
HIGH…r-dbt/dagster_dbt_tests/perf_tests/test_import_perf.py42 "`python -X importtime python_modules/libraries/dagster-dbt/dagster_dbt_tests/perf_tests/simple_import.py noop &CODE
HIGH…sts/unit_tests/in_airflow_tests/test_parse_metadata.py16 "jsonString": '{"class_ref": {"class_name": "DefaultProxyToDagsterOperator", "module_path": "dagster_airCODE
HIGH…ake_pandas_tests/test_snowflake_pandas_type_handler.py178 assert df.equals(DataFrame([{"col1": "a", "col2": 1}]))CODE
HIGH…ake_polars_tests/test_snowflake_polars_type_handler.py244 assert df.equals(pl.DataFrame({"col1": ["a"], "col2": [1]}))CODE
HIGH…ing/dagster_sling_tests/perf_tests/test_import_perf.py43 "`python -X importtime python_modules/libraries/dagster-sling/dagster_sling_tests/perf_tests/simple_import.py &>CODE
HIGH…_tests/cli_tests/import_perf_tests/test_import_perf.py64 "`python -X importtime python_modules/libraries/dagster-dg-cli/dagster_dg_cli_tests/cli_tests/import_perf_tests/CODE
HIGH…dg-cli/dagster_dg_cli/utils/yaml_template_generator.py67 # If all options are null, return nullCOMMENT
HIGH…libraries/dagster-tableau/dagster_tableau/resources.py666 # set them to null), which previously raised a KeyError and failed the load.COMMENT
HIGH…raries/dagster-spark/dagster_spark_tests/test_utils.py139 pytest.param("a && b", ["a", "&&", "b"], id="chain-and"),CODE
HIGH…dules/dagster/dagster_tests/daemon_tests/test_types.py10 ' "DaemonType.SENSOR"}, "error": {"__class__": "SerializableErrorInfo", "cause": null,'CODE
HIGH…dules/dagster/dagster_tests/daemon_tests/test_types.py11 ' "cls_name": null, "message": "fizbuz", "stack": []}, "timestamp": 0.0}'CODE
HIGH…tion_tests/misc_execution_tests/test_asset_backfill.py1821 r' "latest_storage_id": null, "serialized_requested_subset":'CODE
HIGH…tion_tests/misc_execution_tests/test_asset_backfill.py1834 r' null, "serialized_requested_subset": {"partitions_subsets_by_asset_key": {},'CODE
HIGH…tion_tests/misc_execution_tests/test_asset_backfill.py1855 r' []}, "latest_storage_id": null, "serialized_requested_subset":'CODE
HIGH…tests/definitions_tests/test_asset_check_evaluation.py8 ' "AssetCheckSeverity.ERROR"}, "success": true, "target_materialization_data": null}'CODE
HIGH…ster_tests/definitions_tests/test_sensor_invocation.py1049 assert ctx.cursor == "{\"AssetKey(['my_asset'])\": [null, 3, {}]}"CODE
HIGH…les/dagster/dagster_tests/general_tests/test_import.py50 "`python -X importtime python_modules/dagster/dagster_tests/general_tests/import_cli.py &> /tmp/import.txt && tuCODE
HIGH…les/dagster/dagster_tests/general_tests/test_import.py90 "`python -X importtime python_modules/dagster/dagster_tests/general_tests/simple.py &> /tmp/import.txt && tuna /CODE
HIGH…agster/dagster_tests/general_tests/test_serdes_pack.py494 '"record_timestamp": "2026-04-06T11:49:19.912411+00:00", "update_timestamp": null}'CODE
HIGH…les/dagster/dagster_tests/general_tests/test_serdes.py530 assert serialized == '{"__class__": "Foo", "color": "red", "shape": null}'CODE
HIGH…r_tests/general_tests/compat_tests/test_back_compat.py457 old_event_record = """{"__class__":"EventRecord","dagster_event":{"__class__":"DagsterEvent","event_specific_data":nCODE
HIGH…r_tests/general_tests/compat_tests/test_dead_events.py20 old_pipeline_init_failure_event = """{"__class__":"EventRecord","dagster_event":{"__class__":"DagsterEvent","event_sCODE
HIGH…/components_tests/resolution_tests/test_form_schema.py133 # untouched, matching schemaPrep.ts. A non-string variant like {type: null}COMMENT
HIGH…dagster/dagster_tests/core_tests/test_event_logging.py162 ' null, "bar": null, "baz": null, "metadata_entries": [{"__class__": "EventMetadataEntry",'CODE
HIGH…dagster/dagster_tests/core_tests/test_event_logging.py163 ' "description": null, "entry_data": {"__class__": "TextMetadataEntryData", "text": "999"},'CODE
HIGH…dagster/dagster_tests/core_tests/test_event_logging.py165 ' "message": "howdy", "pid": null, "pipeline_name": "nonce", "solid_handle": null,'CODE
HIGH…dagster/dagster_tests/core_tests/test_event_logging.py166 ' "step_handle": null, "step_key": "future_step", "step_kind_value": null}'CODE
HIGH…dagster/dagster_tests/core_tests/test_event_logging.py170 '{"__class__": "DagsterEvent", "event_specific_data": null, "event_type_value":'CODE
HIGH…dagster/dagster_tests/core_tests/test_event_logging.py171 ' "EVENT_TYPE_FROM_THE_FUTURE", "logging_tags": {}, "message": "howdy", "pid": null,'CODE
HIGH…dagster/dagster_tests/core_tests/test_event_logging.py172 ' "pipeline_name": "nonce", "solid_handle": null, "step_handle": null, "step_key":'CODE
HIGH…dagster/dagster_tests/core_tests/test_event_logging.py173 ' "future_step", "step_kind_value": null}'CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py14{"__class__": "DagsterEvent", "event_specific_data": null, "event_type_value": "STEP_START", "logging_tags": {"pipeline"CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py16 event_specific_data = {"step_output_handle": ["do_something", "result"], "type_check_data": [true, "result", null, []]}CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py21{"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepOutputData", "step_output_handle": {"__class__":CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py28{"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepSuccessData", "duration_ms": 13.93123900000015},CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py34{"__class__": "DagsterEvent", "event_specific_data": null, "event_type_value": "STEP_START", "logging_tags": {"pipeline"CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py36 event_specific_data = {"input_name": "x", "type_check_data": [true, "x", null, []]}CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py41{"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepInputData", "input_name": "x", "type_check_data"CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py43 event_specific_data = {"step_output_handle": ["do_input", "result"], "type_check_data": [true, "result", null, []]}CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py48{"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepOutputData", "step_output_handle": {"__class__":CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py55{"__class__": "DagsterEvent", "event_specific_data": {"__class__": "StepSuccessData", "duration_ms": 13.923579000000075}CODE
HIGH…s/dagster/dagster_tests/core_tests/test_event_utils.py71 lid": "do_input", "solid_definition": "do_input", "step_key": "do_input"}, "message": "Finished execution of step \\CODE
HIGH…e_tests/snap_tests/test_old_execution_plan_snapshot.py9 "initial_known_state": null,CODE
HIGH…e_tests/snap_tests/test_old_execution_plan_snapshot.py72 "mapping_key": null,CODE
HIGH…e_tests/snap_tests/test_old_execution_plan_snapshot.py80 "mapping_key": null,CODE
HIGH…e_tests/snap_tests/test_old_execution_plan_snapshot.py146 "initial_known_state": null,CODE
HIGH…_tests/host_representation_tests/test_external_data.py1050 '{"__class__": "ExternalSensorData", "description": null, "min_interval": null, "mode":'CODE
HIGH…_tests/host_representation_tests/test_external_data.py1051 ' "default", "name": "my_sensor", "pipeline_name": "my_pipeline", "solid_selection": null}'CODE
HIGH…_tests/host_representation_tests/test_external_data.py1321 ' null, "output_name": null, "partition_mapping": null}], "execution_type": {"__enum__":'CODE
HIGH…_tests/host_representation_tests/test_external_data.py1322 ' "AssetExecutionType.MATERIALIZATION"}, "pools": {"__set__": []}, "compute_kind": null,'CODE
HIGH…_tests/host_representation_tests/test_external_data.py1323 ' "op_name": "op_two", "op_names": ["op_two"], "code_version": null,'CODE
HIGH…_tests/host_representation_tests/test_external_data.py1324 ' "node_definition_name": null, "graph_name": null, "op_description": null, "job_names":'CODE
HIGH…_tests/host_representation_tests/test_external_data.py1325 ' ["a_job"], "partitions_def_data": null, "output_name": null, "metadata_entries": [],'CODE
HIGH…_tests/host_representation_tests/test_external_data.py1326 ' "tags": {}, "group_name": "some_group", "freshness_policy": null,'CODE
HIGH…_tests/host_representation_tests/test_external_data.py1327 ' "new_freshness_policy": null, "is_source": false, "is_observable": false,'CODE
HIGH…_tests/host_representation_tests/test_external_data.py1328 ' "atomic_execution_unit_id": null, "required_top_level_resources": [],'CODE
58 more matches not shown…
Docstring Block Structure117 hits · 585 pts
SeverityFileLineSnippetContext
HIGH…dules/dagster-graphql/dagster_graphql/client/client.py267Submits a job with attached configuration for execution. Args: job_name (str): The job's name STRING
HIGH…dules/dagster-graphql/dagster_graphql/client/client.py315Get the status of a given Pipeline Run. Args: run_id (str): run id of the requested pipeline run. STRING
HIGH…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py1054The list of AssetsDefinition for all connections in the Airbyte workspace. Args: workspace (Union[AirbyteWoSTRING
HIGH…libraries/dagster-airbyte/dagster_airbyte/resources.py573Returns a list of AssetSpecs representing the Airbyte content in the workspace. Args: dagster_airbySTRING
HIGH…libraries/dagster-airbyte/dagster_airbyte/resources.py891Returns a list of AssetSpecs representing the Airbyte content in the workspace. Args: workspace (BaseAirbytSTRING
HIGH…libraries/dagster-airbyte/dagster_airbyte/resources.py969Returns a list of AssetSpecs representing the Airbyte content in the workspace. Args: workspace (AirbyteCloSTRING
HIGH…s/libraries/dagster-github/dagster_github/resources.py175Retrieve the list of installations for the authenticated GitHub App. This method makes a GET request to the GitSTRING
HIGH…s/libraries/dagster-github/dagster_github/resources.py243Execute a GraphQL query against the GitHub API. This method sends a POST request to the GitHub API with the proSTRING
HIGH…s/libraries/dagster-github/dagster_github/resources.py300Create a new issue in the specified GitHub repository. This method first retrieves the repository ID using the STRING
HIGH…s/libraries/dagster-github/dagster_github/resources.py343Create a new reference (branch) in the specified GitHub repository. This method first retrieves the repository STRING
HIGH…s/libraries/dagster-github/dagster_github/resources.py398Create a new pull request in the specified GitHub repository. This method creates a pull request from the head STRING
HIGH…er-snowflake/dagster_snowflake/snowflake_io_manager.py28Builds an IO manager definition that reads inputs from and writes outputs to Snowflake. Args: type_handlersSTRING
HIGH…aries/dagster-snowflake/dagster_snowflake/resources.py626Get a list of databases in Snowflake that match the specified pattern. Retrieves Database objects from SnowflakSTRING
HIGH…aries/dagster-snowflake/dagster_snowflake/resources.py665Get a list of schemas in Snowflake databases that match the specified patterns. Retrieves Schema objects from SSTRING
HIGH…aries/dagster-snowflake/dagster_snowflake/resources.py707Get a list of tables in Snowflake that match the specified patterns. Retrieves Table objects from Snowflake thaSTRING
HIGH…aries/dagster-snowflake/dagster_snowflake/resources.py747Get a list of views in Snowflake that match the specified patterns. Retrieves View objects from Snowflake that STRING
HIGH…aries/dagster-snowflake/dagster_snowflake/resources.py787Get a list of pipes in Snowflake that match the specified patterns. Retrieves Pipe objects from Snowflake that STRING
HIGH…aries/dagster-snowflake/dagster_snowflake/resources.py828Get a list of stages in Snowflake that match the specified patterns. Retrieves Stage objects from Snowflake thaSTRING
HIGH…aries/dagster-snowflake/dagster_snowflake/resources.py925Execute a query in Snowflake. Args: sql (str): the query to be executed parameters (OptSTRING
HIGH…aries/dagster-snowflake/dagster_snowflake/resources.py974Execute multiple queries in Snowflake. Args: sql_queries (str): List of queries to be executed in sSTRING
HIGH…/libraries/dagster-duckdb/dagster_duckdb/io_manager.py29Builds an IO manager definition that reads inputs from and writes outputs to DuckDB. Args: type_handlers (SSTRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py108Given a parsed manifest and a dbt unique_id, returns the dictionary of properties for the corresponding dbt resoSTRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py326A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster asset key STRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py411A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster descriptioSTRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py443A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster metadata fSTRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py475A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster tags for tSTRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py515A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster group nameSTRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py547A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster code versiSTRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py579A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster owners forSTRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py614A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster :py:class:STRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py669A function that takes a dictionary representing properties of a dbt resource, and returns the Dagster :py:class:STRING
HIGH…ries/dagster-dbt/dagster_dbt/dagster_dbt_translator.py725[INTERNAL] A function that takes a dictionary representing properties of a dbt resource, and returns the DagsterSTRING
HIGH…dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py143Return the corresponding Dagster asset key for a dbt model, seed, or snapshot. Args: dbt_assets (AssetsDefiSTRING
HIGH…dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py193Returns the corresponding Dagster asset keys for all tables in a dbt source. This is a convenience method that makeSTRING
HIGH…dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py252Returns the corresponding Dagster asset key for a dbt source with a singular table. Args: source_name (str)STRING
HIGH…dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py296Build an asset selection for a dbt selection string. See https://docs.getdbt.com/reference/node-selection/syntax#hoSTRING
HIGH…dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py393Build a schedule to materialize a specified set of dbt resources from a dbt selection string. See https://docs.getdSTRING
HIGH…ies/dagster-dbt/dagster_dbt/core/dbt_cli_invocation.py389Retrieve a dbt artifact from the target path. See https://docs.getdbt.com/reference/artifacts/dbt-artifacts forSTRING
HIGH…les/libraries/dagster-dbt/dagster_dbt/core/resource.py504Create a subprocess to execute a dbt CLI command. Args: args (Sequence[str]): The dbt CLI command tSTRING
HIGH…er-dbt/dagster_dbt/components/dbt_project/component.py254Given a parsed manifest and a dbt unique_id, returns the dictionary of properties for the corresponding dbt resoSTRING
HIGH…/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py561Loads a set of dbt models, managed by a dbt Cloud job, into Dagster assets. In order to determine the set of dbt modSTRING
HIGH…s/libraries/dagster-dbt/dagster_dbt/cloud/resources.py187Updates specific properties of a dbt job. Documentation on the full set of potential parameters can be found heSTRING
HIGH…ries/dagster-airlift/dagster_airlift/core/load_defs.py89Builds a :py:class:`dagster.Definitions` object from an Airflow instance. For every DAG in the Airflow instance, thSTRING
HIGH…libraries/dagster-pandas/dagster_pandas/constraints.py679Factory for validators testing if column values are within a range. Args: minim(Optional[Comparable]): the STRING
HIGH…libraries/dagster-pandas/dagster_pandas/constraints.py795Factory for testing if the dtype of a val falls within some allowed set. Args: datatypes(Union[set[type], tSTRING
HIGH…braries/dagster-gcp/dagster_gcp/bigquery/io_manager.py37Builds an I/O manager definition that reads inputs from and writes outputs to BigQuery. Args: type_handlersSTRING
HIGH…modules/libraries/dagster-ssh/dagster_ssh/resources.py27Creates a paramiko SSH key from a string. Args: key_str (str): A string containing the private key data. STRING
HIGH…tabricks/components/databricks_asset_bundle/configs.py50Load Databricks bundle configuration with template variables resolved. Uses the Databricks CLI to validate and resoSTRING
HIGH…raries/dagster-fivetran/dagster_fivetran/asset_defs.py722The list of AssetsDefinition for all connectors in the Fivetran workspace. Args: workspace (FivetranWorkspaSTRING
HIGH…braries/dagster-fivetran/dagster_fivetran/resources.py1165Returns a list of AssetSpecs representing the Fivetran content in the workspace. Args: dagster_fiveSTRING
HIGH…braries/dagster-fivetran/dagster_fivetran/resources.py1283Executes a sync and poll process to materialize Fivetran assets. This method can only be used in the contextSTRING
HIGH…braries/dagster-fivetran/dagster_fivetran/resources.py1455Returns a list of AssetSpecs representing the Fivetran content in the workspace. Args: workspace (FivetranWSTRING
HIGH…agster-sling/dagster_sling/dagster_sling_translator.py99A function that takes a stream definition from a Sling replication config and returns a Dagster AssetKey. STRING
HIGH…agster-sling/dagster_sling/dagster_sling_translator.py149A function that takes a stream definition from a Sling replication config and returns a Dagster AssetKey. STRING
HIGH…dg_cli_tests/cli_tests/api_tests/shared/yaml_loader.py12Load fixture scenarios from a YAML file. Args: yaml_file: Path to YAML file containing fixture scenario defSTRING
HIGH…gster-dg-cli/dagster_dg_cli/cli/scaffold/branch/git.py26Run a git command and return the result. Args: args: List of git command arguments (without 'git' prefix) STRING
HIGH…gster-dg-cli/dagster_dg_cli/cli/scaffold/branch/git.py96Create and checkout a new git branch. Args: branch_name: Name of the branch to create Returns: STRING
HIGH…gster-dg-cli/dagster_dg_cli/cli/scaffold/branch/git.py126Create a commit with current changes and optionally push to remote. Args: message: Commit message lSTRING
HIGH…gster-dg-cli/dagster_dg_cli/cli/scaffold/branch/git.py156Push the current branch to remote and create a GitHub pull request. Args: branch_name: Name of the branch tSTRING
HIGH…-dg-cli/dagster_dg_cli/cli/scaffold/branch/planning.py64Generate initial implementation plan from user input. Args: context: Planning context with user inpSTRING
57 more matches not shown…
Excessive Try-Catch Wrapping502 hits · 523 pts
SeverityFileLineSnippetContext
LOWRUN_API_IMPLEMENTATION_PLAN.md457 except Exception as e:CODE
LOWRUN_API_IMPLEMENTATION_PLAN.md555 except Exception as e:CODE
LOW…/dagster-graphql/dagster_graphql/schema/instigation.py388 except Exception:CODE
LOW…/dagster-graphql/dagster_graphql/schema/instigation.py419 except Exception:CODE
LOW…les/dagster-graphql/dagster_graphql/schema/backfill.py260 except Exception:CODE
LOW…dules/dagster-graphql/dagster_graphql/schema/errors.py41 except Exception as e:STRING
LOW…dules/dagster-graphql/dagster_graphql/schema/errors.py43 except Exception as e:STRING
LOW…dules/dagster-graphql/dagster_graphql/schema/errors.py57 except Exception as e:STRING
LOW…dules/dagster-graphql/dagster_graphql/schema/errors.py59 except Exception as e:STRING
LOW…agster-graphql/dagster_graphql/implementation/utils.py575 except Exception as exc:CODE
LOW…agster-graphql/dagster_graphql/implementation/utils.py589 except Exception as exc:CODE
LOW…ter-graphql/dagster_graphql/implementation/external.py62 except Exception:CODE
LOW…dules/dagster-graphql/dagster_graphql/client/client.py135 except Exception as exc: # catch generic Exception from the gql clientCODE
LOW…ules/dagster-graphql/dagster_graphql_tests/test_cli.py194 except Exception as e:STRING
MEDIUM…/dagster-graphql/dagster_graphql_tests/graphql/repo.py547def throw_a_thing():CODE
LOW…/dagster-graphql/dagster_graphql_tests/graphql/repo.py554 except Exception as e:CODE
LOW…/dagster-graphql/dagster_graphql_tests/graphql/repo.py556 except Exception as e:CODE
LOW…/dagster-graphql/dagster_graphql_tests/graphql/repo.py1243 except Exception:CODE
LOW…er-snowflake/dagster_snowflake/snowflake_io_manager.py381 except Exception as e:CODE
LOW…/dagster_snowflake/components/dbt_project/component.py617 except Exception as e:CODE
LOW…/dagster_snowflake/components/dbt_project/component.py307 except Exception as e:CODE
LOW…/dagster_snowflake/components/dbt_project/component.py745 except Exception as e:CODE
LOW…/dagster_snowflake/components/dbt_project/component.py813 except Exception:CODE
LOW…/dagster_snowflake/components/dbt_project/component.py870 except Exception as e:CODE
LOW…/dagster_snowflake/components/dbt_project/component.py1085 except Exception as e:CODE
LOW…/dagster_snowflake/components/dbt_project/component.py1095 except Exception as e:CODE
LOW…/dagster_snowflake/components/dbt_project/component.py1193 except Exception as e:CODE
LOW…/dagster_snowflake/components/dbt_project/component.py1218 except Exception as e:CODE
LOW…ter-cloud-cli/dagster_cloud_cli/core/graphql_client.py209 except Exception as e:CODE
LOW…r-cloud-cli/dagster_cloud_cli/core/pex_builder/deps.py435 except Exception as e:CODE
LOW…li/dagster_cloud_cli/core/pex_builder/code_location.py68 except Exception:CODE
LOW…agster-cloud-cli/dagster_cloud_cli/commands/metrics.py99 except Exception:CODE
LOW…ster-cloud-cli/dagster_cloud_cli/commands/ci/checks.py132 except Exception as err:CODE
LOW…er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py340 except Exception as error:CODE
LOW…er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py349 except Exception as err:CODE
LOW…er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py375 except Exception as err:CODE
LOW…gster_cloud_cli/commands/integration/atlan/__init__.py46 except Exception as e:CODE
LOW…gster_cloud_cli/commands/integration/atlan/__init__.py62 except Exception as e:CODE
LOW…d-cli/dagster_cloud_cli/commands/workspace/__init__.py45 except Exception as e:CODE
LOW…d-cli/dagster_cloud_cli/commands/workspace/__init__.py150 except Exception as e:CODE
LOW…d-cli/dagster_cloud_cli/commands/workspace/__init__.py160 except Exception as e:CODE
LOW…d-cli/dagster_cloud_cli/commands/workspace/__init__.py222 except Exception as e:CODE
LOW…d-cli/dagster_cloud_cli/commands/workspace/__init__.py357 except Exception as e:CODE
LOW…oud_cli/commands/deployment/alert_policies/commands.py51 except Exception as e:CODE
LOW…r-cloud-cli/dagster_cloud_cli/commands/job/__init__.py101 except Exception as e:CODE
LOW…r-cloud-cli/dagster_cloud_cli/commands/run/__init__.py26 except Exception as e:CODE
LOW…braries/dagster-deltalake/dagster_deltalake/handler.py96 except Exception:CODE
LOW…braries/dagster-deltalake/dagster_deltalake/handler.py144 except Exception as e:CODE
LOW…ibraries/dagster-dlt/dagster_dlt/dlt_event_iterator.py57 except Exception as e:CODE
LOW…s/dagster-azure/dagster_azure/pipes/message_readers.py64 except Exception:CODE
LOW…s/dagster-azure/dagster_azure/pipes/message_readers.py74 except Exception:CODE
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py84def worker() -> None:CODE
LOW…s/dagster-postgres/dagster_postgres_tests/test_auth.py87 except Exception as e:CODE
LOW…s/dagster-postgres/dagster_postgres_tests/test_auth.py134 except Exception:CODE
LOW…on_modules/libraries/dagster-k8s/dagster_k8s/client.py526 except Exception as e:CODE
LOW…on_modules/libraries/dagster-k8s/dagster_k8s/client.py532 except Exception as e:CODE
MEDIUM…on_modules/libraries/dagster-k8s/dagster_k8s/client.py486def _get_job_status():CODE
LOW…hon_modules/libraries/dagster-k8s/dagster_k8s/pipes.py167 except Exception as e:CODE
LOW…hon_modules/libraries/dagster-k8s/dagster_k8s/pipes.py324 except Exception:CODE
LOW…_modules/libraries/dagster-k8s/dagster_k8s/launcher.py376 except Exception:CODE
442 more matches not shown…
Decorative Section Separators151 hits · 516 pts
SeverityFileLineSnippetContext
MEDIUM…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py1042# -----------------------COMMENT
MEDIUM…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py1044# -----------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py51# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py53# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py139# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py141# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py173# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py175# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py227# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py229# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py782# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py784# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py279# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py281# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py478# ---------------------------------------------------------------------------COMMENT
MEDIUM…/dagster_snowflake_tests/test_dbt_project_component.py480# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py19# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py21# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py38# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py40# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py73# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py75# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py102# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py104# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py142# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py144# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py178# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py180# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py207# ---------------------------------------------------------------------------COMMENT
MEDIUM…s/dagster-postgres/dagster_postgres_tests/test_auth.py209# ---------------------------------------------------------------------------COMMENT
MEDIUM…gster-dbt/dagster_dbt_tests/cloud_v2/test_resources.py318# ----------------------------------------------------------------------------COMMENT
MEDIUM…gster-dbt/dagster_dbt_tests/cloud_v2/test_resources.py320# ----------------------------------------------------------------------------COMMENT
MEDIUM…raries/dagster-fivetran/dagster_fivetran/asset_defs.py711# -----------------------COMMENT
MEDIUM…raries/dagster-fivetran/dagster_fivetran/asset_defs.py713# -----------------------COMMENT
MEDIUM…braries/dagster-fivetran/dagster_fivetran/resources.py487# ------------------COMMENT
MEDIUM…braries/dagster-fivetran/dagster_fivetran/resources.py489# ------------------COMMENT
MEDIUM…i_tests/cli_tests/api_tests/run_tests/test_get_logs.py125# ---------------------------------------------------------------------------COMMENT
MEDIUM…i_tests/cli_tests/api_tests/run_tests/test_get_logs.py127# ---------------------------------------------------------------------------COMMENT
MEDIUM…_tests/cli_tests/api_tests/run_tests/test_get_ticks.py15# ---------------------------------------------------------------------------COMMENT
MEDIUM…_tests/cli_tests/api_tests/run_tests/test_get_ticks.py17# ---------------------------------------------------------------------------COMMENT
MEDIUM…_tests/cli_tests/api_tests/run_tests/test_get_ticks.py92# ---------------------------------------------------------------------------COMMENT
MEDIUM…_tests/cli_tests/api_tests/run_tests/test_get_ticks.py94# ---------------------------------------------------------------------------COMMENT
MEDIUM…_tests/cli_tests/api_tests/run_tests/test_get_ticks.py159# ---------------------------------------------------------------------------COMMENT
MEDIUM…_tests/cli_tests/api_tests/run_tests/test_get_ticks.py161# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py175# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py177# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py256# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py258# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py1103# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py1105# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py107# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py109# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py136# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py138# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py193# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py195# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py206# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py208# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py229# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/dagster-dg-cli/dagster_dg_cli/cli/api/formatters.py231# ---------------------------------------------------------------------------COMMENT
91 more matches not shown…
Self-Referential Comments190 hits · 502 pts
SeverityFileLineSnippetContext
MEDIUMconftest.py44 # Create a section break in the logs any time Buildkite invokes pytestCOMMENT
MEDIUM…on_modules/dagster-test/dagster_test/dg_utils/utils.py344 # Create a venv capable of running dagster devCOMMENT
MEDIUM…on_modules/dagster-test/dagster_test/dg_utils/utils.py830 # Create a buffer for the resultCOMMENT
MEDIUM…r-graphql/dagster_graphql_tests/graphql/test_assets.py3834 # Create a context with permissions in one locationCOMMENT
MEDIUM…phql_tests/graphql/test_asset_condition_evaluations.py850 # Create an evaluation with SinceCondition metadataCOMMENT
MEDIUM…-graphql/dagster_graphql_tests/graphql/test_context.py85 # Create a request context from the process contextCOMMENT
MEDIUM…ql/dagster_graphql_tests/graphql/test_captured_logs.py124 # Create a unique log key for this testSTRING
MEDIUM…ql/dagster_graphql_tests/graphql/test_captured_logs.py172 # Create a unique log key for this testSTRING
MEDIUM…libraries/dagster-airbyte/dagster_airbyte/resources.py468 """This class represents a Airbyte workspace and provides utilitiesSTRING
MEDIUM…r-airbyte/dagster_airbyte_tests/beta/test_resources.py428 # Create a new resource with the specific cancel_on_termination valueCOMMENT
MEDIUM…r-airbyte/dagster_airbyte_tests/beta/test_resources.py530 # Create a new resource with the specific poll_previous_running_sync valueCOMMENT
MEDIUM…rbyte_tests/test_airbyte_project/api_http_headers.yaml1# This file is an example file with API HTTP headers used to pass to the octavia CLI API client.COMMENT
MEDIUM…dules/libraries/dagster-dask/dagster_dask/resources.py27 # Create a Dask cluster if a cluster config is specified.COMMENT
MEDIUM…s/libraries/dagster-snowflake/dagster_snowflake/ops.py27 """This function is a solid factory that constructs solids to execute a snowflake query.STRING
MEDIUM…s/libraries/dagster-snowflake/dagster_snowflake/ops.py45 """This function is an op factory that constructs an op to execute a snowflake query.STRING
MEDIUM…ies/dagster-snowflake/dagster_snowflake_tests/utils.py65 # Create a temporary table to base the view onCOMMENT
MEDIUM…ies/dagster-snowflake/dagster_snowflake_tests/utils.py98 # Create a temporary table and stage for the pipeCOMMENT
MEDIUM…ies/dagster-snowflake/dagster_snowflake_tests/utils.py137 # Create an internal stageCOMMENT
MEDIUM…dagster_cloud_cli_tests/test_pyproject_toml_support.py365 # Create a project with pyproject.tomlCOMMENT
MEDIUM…dagster_cloud_cli_tests/test_pyproject_toml_support.py598 # Create main packageCOMMENT
MEDIUM…dagster_cloud_cli_tests/test_pyproject_toml_support.py338 # Create a simple Python fileSTRING
MEDIUM…dagster_cloud_cli_tests/test_pyproject_toml_support.py396 # Create a nested package structure like:STRING
MEDIUM…dagster_cloud_cli_tests/test_pyproject_toml_support.py469 # Create a requirements.txt that setup.py will readSTRING
MEDIUM…dagster_cloud_cli_tests/test_pyproject_toml_support.py736 # Create main app packageSTRING
MEDIUM…braries/dagster-deltalake/dagster_deltalake/handler.py278 # Create a dataset from actions table and apply filterCOMMENT
MEDIUM…dagster_gcp_pandas_tests/bigquery/test_type_handler.py158 # Create a job with the temporary table name as an output, so that it will write to that tableCOMMENT
MEDIUM…on_modules/libraries/dagster-k8s/dagster_k8s/models.py16# Create a single Configuration object to pass through to each model creation -COMMENT
MEDIUM…es/libraries/dagster-k8s/dagster_k8s/ops/k8s_job_op.py172 """This function is a utility for executing a Kubernetes job from within a Dagster op.STRING
MEDIUM…dagster-k8s/dagster_k8s_tests/unit_tests/test_pipes.py479 # Create a mock message reader that is an instance of PipesK8sPodLogsMessageReaderCOMMENT
MEDIUM…agster-k8s/dagster_k8s_tests/unit_tests/test_models.py151 # Creating a model should not use the logger lockCOMMENT
MEDIUM…agster_gcp_pyspark_tests/bigquery/test_type_handler.py210 # Create a job with the temporary table name as an output, so that it will write to that tableCOMMENT
MEDIUM…ibraries/dagster-dbt/dagster_dbt/cloud_v2/resources.py78 """This class represents a dbt Cloud workspace and provides utilitiesSTRING
MEDIUM…ies/dagster-dbt/dagster_dbt/core/dbt_cli_invocation.py175 # Create a subprocess that runs the dbt CLI command.COMMENT
MEDIUM…es/libraries/dagster-dbt/dagster_dbt_tests/conftest.py200 # Create the source_raw_customers table in DuckDB before dbt runs.COMMENT
MEDIUM…es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh391 # Create the directory if it doesn't existCOMMENT
MEDIUM…gster-dbt/dagster_dbt_tests/cloud_v2/test_resources.py122 # Create a workspace with custom ad hoc job nameCOMMENT
MEDIUM…gster-dbt/dagster_dbt_tests/core/test_temp_selector.py210 # Create a large select expression that exceeds the threshold when combined with excludeSTRING
MEDIUM…-dbt/dagster_dbt_tests/cli/test_prepare_and_package.py209 # Create a dependencies.yml fileCOMMENT
MEDIUM…libraries/dagster-airlift/dagster_airlift/mwaa/auth.py81 # Create a new sessionCOMMENT
MEDIUM…unit_tests/in_airflow_tests/test_no_dagster_install.py18 # Create a new virtual environment using uvCOMMENT
MEDIUM…ift_tests/unit_tests/core_tests/test_monitoring_job.py423 # Create an actual run for the monitoring job that is not finished.COMMENT
MEDIUM…ift_tests/unit_tests/core_tests/test_monitoring_job.py570 # Create an actual run for the monitoring job that is failed.COMMENT
MEDIUM…ift_tests/unit_tests/core_tests/test_monitoring_job.py581 # Create a successful run for the monitoring job within the same run group.COMMENT
MEDIUM…les/libraries/dagster-airlift/scripts/airflow_setup.sh20# Create the airflow.cfg file in the specified AIRFLOW_HOME_DIRCOMMENT
MEDIUM…aries/dagster-airlift/perf-harness/perf_harness/cli.py81 # Create an ephemeral file where the results will be written, and assign it in shared.constants.pyCOMMENT
MEDIUM…lift/perf-harness/perf_harness/dagster_defs/observe.py30 # Create a bunch of dependencies for each asset.COMMENT
MEDIUM…lift/perf-harness/perf_harness/dagster_defs/migrate.py37 # Create a bunch of dependencies for each asset.COMMENT
MEDIUM…ake_pandas_tests/test_snowflake_pandas_type_handler.py225 # Create a job with the temporary table name as an output, so that it will write to that tableCOMMENT
MEDIUM…libraries/dagster-pandas/dagster_pandas/constraints.py426 """This class is useful for constructing single constraints that you want to apply to multipleSTRING
MEDIUM…libraries/dagster-pandas/dagster_pandas/constraints.py481 """This class is useful for constructing more complicated relationships between columnsSTRING
MEDIUM…libraries/dagster-pandas/dagster_pandas/constraints.py564 """This class is similar to multicolumn, but takes in functions that operate on the whole column at onceSTRING
MEDIUM…ake_polars_tests/test_snowflake_polars_type_handler.py268 # Create a job with the temporary table name as an output, so that it will write to that tableCOMMENT
MEDIUM…gcp/dagster_gcp_tests/dataproc_tests/test_resources.py122 # Create a single-node clusterCOMMENT
MEDIUM…gcp/dagster_gcp_tests/dataproc_tests/test_resources.py175 # Create a single-node clusterCOMMENT
MEDIUM…gcp/dagster_gcp_tests/dataproc_tests/test_resources.py231 # Create a single-node clusterCOMMENT
MEDIUM…gcp/dagster_gcp_tests/dataproc_tests/test_resources.py284 # Create a single-node clusterCOMMENT
MEDIUM…gcp/dagster_gcp_tests/dataproc_tests/test_resources.py331 # Create a single-node clusterCOMMENT
MEDIUM…s/dagster-sigma/dagster_sigma_tests/test_translator.py140 # Create a workbook that references a table inode that doesn't existCOMMENT
MEDIUM…sql/dagster_mysql/schedule_storage/schedule_storage.py188 # Define the base insert statementCOMMENT
MEDIUM…sql/dagster_mysql/schedule_storage/schedule_storage.py201 # Define the upsert statement using the ON DUPLICATE KEY UPDATE syntax for MySQLCOMMENT
130 more matches not shown…
Modern AI Meta-Vocabulary100 hits · 266 pts
SeverityFileLineSnippetContext
MEDIUMpyproject.toml94# Project-scaffold templates; the PROJECT_NAME_PLACEHOLDER is substituted at generation time.COMMENT
MEDIUMREADME.md96### Dagster as a robust orchestration engineCOMMENT
MEDIUMCHANGES.md1349### `create-dagster` — one-shot project scaffoldCOMMENT
MEDIUM…on_modules/dagster-test/dagster_test/dg_utils/utils.py899 # We need to find the right spot to inject global options. For the `dg scaffold`COMMENT
MEDIUM…es/libraries/create-dagster/create_dagster/scaffold.py29 # add create-dagster to editable installs so you can scaffold projects in theCOMMENT
MEDIUM…gster_dlt/components/dlt_load_collection/scaffolder.py126 # Given source and destination, we can use dlt init to scaffold the sourceCOMMENT
MEDIUMpython_modules/libraries/dagster-soda/README.md27Use the Dagster CLI to scaffold a new Soda scan component in your project (requires [dagster-dg-cli](https://docs.dagsteCODE
MEDIUM…es/dagster-soda/dagster_soda_tests/test_integration.py100 # Default scaffold uses "my_table" in checks and asset_key_mapCOMMENT
MEDIUM…/libraries/dagster-pandera/dagster_pandera/__init__.py16# However, some commented-out scaffolding has been left in place for support ofCOMMENT
MEDIUM…es/dagster-fivetran/dagster_fivetran/sensor_builder.py147 # New successful sync — check if the orchestration path already materialized this syncCOMMENT
MEDIUM…raries/dagster-fivetran/dagster_fivetran/translator.py343 # the polling sensor and Dagster-triggered (orchestration) syncs.COMMENT
MEDIUM…r-fivetran/dagster_fivetran_tests/test_sensor_dedup.py136 # Simulate orchestration having already written materializationsCOMMENT
MEDIUM…r-fivetran/dagster_fivetran_tests/test_sensor_dedup.py203 # Simulate orchestration materialized sync A (NEW_SYNC_TIME_STR)COMMENT
MEDIUM…r-fivetran/dagster_fivetran_tests/test_sensor_dedup.py217 # Set cursor to sync A's timestamp (orchestration already handled it)COMMENT
MEDIUM…gster_dg_cli_tests/cli_tests/test_scaffold_commands.py436 # runner.invoke("scaffold", "component", "Baz")COMMENT
MEDIUM…gster_dg_cli_tests/cli_tests/test_scaffold_commands.py437 # assert_runner_result(runner.invoke("scaffold", "component", "Baz"))COMMENT
MEDIUM…gster_dg_cli_tests/cli_tests/test_scaffold_commands.py213 # dg scaffold defs foo_bar.components.baz.Baz should still workCOMMENT
MEDIUM…gster_dg_cli_tests/cli_tests/test_scaffold_commands.py861 # SimplePipesScriptComponent has scaffold params, so --json-params should be definedSTRING
MEDIUM…gster_dg_cli_tests/cli_tests/test_scaffold_commands.py868 # AllMetadataEmptyComponent does not have scaffold params, so --json-params should not beSTRING
MEDIUM…gster_dg_cli_tests/cli_tests/test_scaffold_commands.py765 # First, try scaffolding with multiple options using --asset-keySTRING
MEDIUM…gster_dg_cli_tests/cli_tests/test_scaffold_commands.py829 # Check for simple job scaffoldingSTRING
MEDIUM…_dg_cli_tests/cli_tests/test_environment_validation.py188# `dg scaffold` is special because global options have to be inserted before theCOMMENT
MEDIUM…ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py42# The `dg scaffold defs` command is special because its subcommands are dynamically generatedCOMMENT
MEDIUM…ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py138 # json_params will not be present in the key_value_params if no scaffold propertiesSTRING
MEDIUM…ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py143 # default to python for decorator scaffolding. Default is YAML (set by option) forSTRING
MEDIUM…ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py174 # If there are defined scaffold properties, add them to the command. Also only addSTRING
MEDIUM…ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py175 # `--json-params` if there are defined scaffold properties.STRING
MEDIUM…ies/dagster-dg-cli/dagster_dg_cli/cli/scaffold/defs.py258 # pull parameters directly off the target command. For these component scaffold subcommands we needSTRING
MEDIUM…dagster-dg-cli/dagster_dg_cli/cli/scaffold/__init__.py21# Register all scaffold commands from submodulesCOMMENT
MEDIUM…er-dg-cli/dagster_dg_cli/cli/scaffold/branch/CLAUDE.md30 ├── best_practices.md # Best practices for scaffoldingCODE
MEDIUM…er-dg-cli/dagster_dg_cli/cli/scaffold/branch/CLAUDE.md31 └── scaffolding_instructions.md # Content scaffolding instructionsCODE
MEDIUM…agster_dg_cli/cli/scaffold/branch/claude/sdk_client.py89 permission_mode="acceptEdits", # Auto-accept file edits for scaffoldingCODE
MEDIUM…cli/plus/deploy/configure/configure_build_artifacts.py36 # For serverless with PEX deploys, skip scaffolding build artifactsCOMMENT
MEDIUM…gster_dg_cli/cli/plus/deploy/configure/configure_ci.py324 # No CI/CD scaffolding requestedCOMMENT
MEDIUM…i/dagster_dg_cli/cli/plus/deploy/configure/commands.py214 # Resolve organization, URL, and deployment (only needed if scaffolding CI/CD)COMMENT
MEDIUM…ries/dagster-dg-core/dagster_dg_core/shared_options.py87# When set, this will cause project scaffolding to default to --use-editable-dagster mode.STRING
MEDIUM…s/libraries/dagster-dg-core/dagster_dg_core/context.py486 # it uses for all component type scaffolding operations.COMMENT
MEDIUMpython_modules/dagster/README.md96### Dagster as a robust orchestration engineCOMMENT
MEDIUM…gster/dagster_tests/cli_tests/test_project_commands.py160# `dagster project scaffold-code-location` command is deprecated.COMMENT
MEDIUM…gster/dagster_tests/cli_tests/test_project_commands.py199# `dagster project scaffold-repository` command is deprecated.COMMENT
MEDIUM…agster/_core/definitions/metadata/external_metadata.py29# Infer the type from the raw value on the orchestration endCOMMENT
MEDIUM…ules/dagster/dagster/components/component/component.py169 dg scaffold defs MyComponent path/to/component # Generate component instance with scaffoldingSTRING
MEDIUM…dagster/dagster/components/lib/shim_components/base.py13 # temporary hack as currently all scaffold requests target directoriesCOMMENT
MEDIUM…odules/dagster/dagster/components/scaffold/scaffold.py107 # target path for the scaffold request. Typically used to construct absolute pathsCOMMENT
MEDIUM…odules/dagster/dagster/components/scaffold/scaffold.py113 # optional params for scaffoldingCOMMENT
MEDIUM…thon_modules/dagster/dagster/_cli/config_scaffolder.py37 # scaffolding logic, which might not be wise.COMMENT
MEDIUMpython_modules/dagster-pipes/dagster_pipes/__init__.py155# Infer the type from the raw value on the orchestration endCOMMENT
MEDIUM…on/dagster_dev/commands/browse_scaffold_branch_logs.py30 # Check if directory contains any scaffold diagnostic filesCOMMENT
MEDIUM.claude/python_packages.md27## container orchestrationCOMMENT
MEDIUMty/master/pyproject.toml407 # Deliberately-malformed scaffold used as a fixture for notebook-creation tests.COMMENT
MEDIUMdocs/docs/dagster-basics-tutorial/1-assets.md15When building assets, the first step is to scaffold an assets file with the [`dg scaffold` command](/api/clis/dg-cli/dg-CODE
MEDIUMdocs/docs/integrations/libraries/dbt/reference.md21| [`dagster-dbt project scaffold`](/integrations/libraries/dbt/dagster-dbt#scaffold) CODE
MEDIUMdocs/docs/integrations/libraries/dbt/reference.md58You can create a Dagster project that wraps your dbt project by using the [`dagster-dbt project scaffold`](/integrationsCODE
MEDIUMdocs/docs/integrations/libraries/dbt/reference.md79In the Dagster project created by the [`dagster-dbt project scaffold`](/integrations/libraries/dbt/dagster-dbt#scaffold)CODE
MEDIUM…integrations/libraries/dbt/dbt-migration-components.md12The first step is to [scaffold a dbt component definition](/integrations/libraries/dbt#step-3-scaffold-a-dbt-component-dCODE
MEDIUM…t-with-dagster-plus/serverless/existing-dbt-project.md47- Dagster+ will create a new Dagster project in the repository using the [`dagster-dbt scaffold`](/integrations/librarieCODE
MEDIUMdocs/docs/integrations/libraries/soda/index.md35Use the Dagster CLI to scaffold a new Soda scan component in your project. This requires [dagster-dg-cli](https://docs.dCODE
MEDIUM…l-pipelines/dagster-pipes-details-and-customization.md42### Session lifecycle (orchestration process)COMMENT
MEDIUMdocs/docs/getting-started/quickstart.md159Use the [`dg scaffold defs`](/api/clis/dg-cli/dg-cli-reference#dg-scaffold) command to generate an assets file on the coCODE
MEDIUMdocs/docs/getting-started/quickstart.md2792. In the root directory of your project, run [`dg scaffold build-artifacts`](/api/clis/dg-cli/dg-cli-reference#dg-scaffCODE
40 more matches not shown…
Over-Commented Block224 hits · 203 pts
SeverityFileLineSnippetContext
LOWpyproject.toml41asyncio_default_fixture_loop_scope = "session"COMMENT
LOW…modules/dagster-test/dagster_test/dg_utils/__init__.py1# Test utilities for dagster-dg packagesCOMMENT
LOW…on_modules/dagster-test/dagster_test/dg_utils/utils.py781 # below tests.COMMENT
LOW…aphql/dagster_graphql_tests/graphql/test_composites.py21# (+4)COMMENT
LOW…dagster/create_dagster_tests/test_scaffold_commands.py101# dagster (i.e. from the same commit), and the only way to achieve this right now isCOMMENT
LOW…odules/libraries/dagster-dask/dagster_dask/executor.py301 # if address is set, don't add LocalCluster argsCOMMENT
LOW…gster-postgres/dagster_postgres/event_log/event_log.py281 # queries against the event log.COMMENT
LOW…dagster-airflow/dagster_airflow_tests/airflow_utils.py1COMPLEX_DAG_FILE_CONTENTS = '''#COMMENT
LOW…dagster-airflow/dagster_airflow_tests/airflow_utils.py261#COMMENT
LOW…dagster-airflow/dagster_airflow_tests/airflow_utils.py601 create_tag >> update_tag >> delete_tagCOMMENT
LOW…_modules/libraries/dagster-dbt/dagster_dbt/__init__.py81COMMENT
LOW…les/libraries/dagster-dbt/dagster_dbt/core/resource.py661 # An environment variable to indicate that the dbt CLI is being invoked from Dagster.COMMENT
LOW…/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py241 # Fetch information about the job.COMMENT
LOW…/libraries/dagster-pandera/dagster_pandera/__init__.py1import itertoolsCOMMENT
LOW…/libraries/dagster-gcp/dagster_gcp/bigquery/configs.py181 query_parameters = Field(COMMENT
LOW…n_modules/libraries/dagstermill/dagstermill/factory.py201 # Retry on kernel startup failures caused by ZMQ port collisions. WhenCOMMENT
LOW…/dagster-ge/dagster_ge_tests/gx/great_expectations.yml1# Welcome to Great Expectations! Always know what to expect from your data.COMMENT
LOW…-cli/dagster_dg_cli/cli/plus/deploy/configure/utils.py121 # pod_template_spec_metadata: # Metadata for the code server podCOMMENT
LOW…-cli/dagster_dg_cli/cli/plus/deploy/configure/utils.py141 # job_spec_config: # Config for the Kubernetes job for the runCOMMENT
LOW…-cli/dagster_dg_cli/cli/plus/deploy/configure/utils.py161 # run_resources: # Resources for runs launched by the agent for this locationCOMMENT
LOW…-cli/dagster_dg_cli/cli/plus/deploy/configure/utils.py181 # run_sidecar_containers:COMMENT
LOW…/dagster-aws/dagster_aws_tests/pipes_tests/test_ecs.py221 # dense with sqlalchemy GC callbacks, so a single SIGTERM lands in aCOMMENT
LOW…n_modules/libraries/dagster-aws/dagster_aws/emr/emr.py1# Portions of this file are copied from the Yelp MRJob project:COMMENT
LOW…libraries/dagster-aws/dagster_aws/utils/mrjob/log4j.py1# Copyright 2015-2016 YelpCOMMENT
LOW…libraries/dagster-aws/dagster_aws/utils/mrjob/retry.py1# This file duplicated from the Yelp MRJob project:COMMENT
LOW…libraries/dagster-aws/dagster_aws/utils/mrjob/utils.py1# This file duplicated from the Yelp MRJob project:COMMENT
LOW…ibraries/dagster-dg-core/dagster_dg_core/completion.py1import clickCOMMENT
LOW…aries/dagster-shared/dagster_shared/check/functions.py21Numeric: TypeAlias = int | floatCOMMENT
LOW…aries/dagster-shared/dagster_shared/check/functions.py41# - Parameter checks (`<type>_param`): Used to type-check the arguments to a function, typicallyCOMMENT
LOW…aries/dagster-shared/dagster_shared/check/functions.py621# NOTE: inst() and opt_inst() perform narrowing, while inst_param() and opt_inst_param() do not. TheCOMMENT
LOW…owflake-pyspark/dagster_snowflake_pyspark/constants.py1# Description: This file contains the Snowflake connection identifiers for the Snowflake partner account.COMMENT
LOW…l_tests/compat_tests/test_change_snapshot_structure.py41# from dagster import solid, DagsterInstance, execute_pipelineCOMMENT
LOW…/dagster_dev_command_tests/test_dagster_dev_command.py301COMMENT
LOW…/dagster/dagster_tests/utils_tests/test_annotations.py101 )COMMENT
LOW…les/dagster/dagster_tests/core_tests/test_data_time.py21@pytest.mark.parametrize(COMMENT
LOW…/declarative_automation_tests/daemon_tests/test_e2e.py621COMMENT
LOWpython_modules/dagster/dagster/__init__.py1import sysCOMMENT
LOWpython_modules/dagster/dagster/__init__.py21# ### dagster/foo/bar.pyCOMMENT
LOW…les/dagster/dagster/_utils/caching_instance_queryer.py781 # expensive, so we try to avoid doing so in as many situations as possibleCOMMENT
LOWpython_modules/dagster/dagster/_grpc/server.py1561 # E0625 08:46:56.180112000 4697443776 server_chttp2.cc:40]COMMENT
LOW…gster/dagster/_core/storage/event_log/sql_event_log.py581 check.str_param(run_id, "run_id")COMMENT
LOWpython_modules/dagster/dagster/_core/execution/api.py41# | --------------------------- | ------------------ | ----- | ----------- | ----------------------- |COMMENT
LOW…/dagster/dagster/_core/execution/context/invocation.py221 )COMMENT
LOW…ster/dagster/_core/execution/plan/compute_generator.py141COMMENT
LOW…hon_modules/dagster/dagster/_core/snap/job_snapshot.py61def _create_job_snapshot_id(job_snap: "JobSnap"):COMMENT
LOWpython_modules/dagster/dagster/_core/instance/utils.py21# actually using this constants.COMMENT
LOW…ules/dagster/dagster/_core/instance/runs/run_domain.py161COMMENT
LOWpython_modules/dagster/dagster/_core/events/__init__.py2181 )COMMENT
LOWpython_modules/dagster/dagster/_core/events/__init__.py2201# class AssetStoreOperationData(NamedTuple):COMMENT
LOW…ules/dagster/dagster/_core/definitions/data_version.py541 # never been materialized)COMMENT
LOW…hon_modules/dagster/dagster/_core/definitions/utils.py461 selection = check.not_none(sensor.asset_selection)COMMENT
LOW…ster/_core/definitions/assets/definition/asset_spec.py41 from dagster._core.definitions.assets.definition.assets_definition import AssetsDefinitionCOMMENT
LOW…ster/_core/definitions/assets/definition/asset_spec.py61COMMENT
LOWpython_modules/dagster/dagster/_cli/api.py361COMMENT
LOW…on_modules/dagster/dagster/_vendored/dateutil/tz/tz.py261COMMENT
LOW…on_modules/dagster/dagster/_vendored/dateutil/tz/tz.py541 out.trans_list_utc = []COMMENT
LOW…on_modules/dagster/dagster/_vendored/dateutil/tz/tz.py561 # seconds to be added to UTC, tt_isdst tells whetherCOMMENT
LOW…on_modules/dagster/dagster/_vendored/dateutil/tz/tz.py581 # by time.COMMENT
LOW…agster/dagster/_config/pythonic_config/typing_utils.py201 """COMMENT
LOW…pos/repo-with-requirements-txt-hashes/requirements.txt741 # viaCOMMENT
164 more matches not shown…
AI Structural Patterns204 hits · 186 pts
SeverityFileLineSnippetContext
LOW…odules/dagster-test/dagster_test/utils/data_factory.py38CODE
LOW…odules/dagster-test/dagster_test/utils/data_factory.py60CODE
LOW…odules/dagster-test/dagster_test/utils/data_factory.py88CODE
LOW…on_modules/dagster-test/dagster_test/dg_utils/utils.py361CODE
LOW…on_modules/dagster-test/dagster_test/dg_utils/utils.py922CODE
LOW…les/dagster-graphql/dagster_graphql/schema/instance.py345CODE
LOW…dules/dagster-graphql/dagster_graphql/client/client.py151CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py61CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py256CODE
LOW…ibraries/dagster-airbyte/dagster_airbyte/asset_defs.py913CODE
LOW…ster-airbyte/dagster_airbyte/managed/reconciliation.py735CODE
LOW…s/libraries/dagster-cloud-cli/dagster_cloud_cli/gql.py573CODE
LOW…s/libraries/dagster-cloud-cli/dagster_cloud_cli/gql.py54CODE
LOW…/dagster-cloud-cli/dagster_cloud_cli/core/workspace.py52CODE
LOW…er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py401CODE
LOW…er-cloud-cli/dagster_cloud_cli/commands/ci/__init__.py643CODE
LOW…r-cloud-cli/dagster_cloud_cli/commands/job/__init__.py21CODE
LOW…gster_cloud_cli/commands/branch_deployment/__init__.py41CODE
LOW…s/libraries/dagster-dlt/dagster_dlt/asset_decorator.py57CODE
LOW…agster-azure/dagster_azure/blob/compute_log_manager.py118CODE
LOWpython_modules/libraries/dagster-k8s/dagster_k8s/job.py120CODE
LOWpython_modules/libraries/dagster-k8s/dagster_k8s/job.py378CODE
LOW…libraries/dagster-k8s/dagster_k8s/container_context.py64CODE
LOW…hon_modules/libraries/dagster-k8s/dagster_k8s/pipes.py448CODE
LOW…_modules/libraries/dagster-k8s/dagster_k8s/launcher.py44CODE
LOW…es/libraries/dagster-k8s/dagster_k8s/ops/k8s_job_op.py142CODE
LOW…-airflow/dagster_airflow/operators/dagster_operator.py40CODE
LOW…s/libraries/dagster-dbt/dagster_dbt/asset_decorator.py30CODE
LOW…dules/libraries/dagster-dbt/dagster_dbt/asset_utils.py380CODE
LOW…es/dagster-dbt/dagster_dbt/cloud_v2/asset_decorator.py27CODE
LOW…agster-dbt/dagster_dbt_tests/core/test_asset_checks.py351CODE
LOW…-airlift/dagster_airlift/test/airflow_test_instance.py359CODE
LOW…r-airlift/dagster_airlift_tests/unit_tests/conftest.py67CODE
LOW…r-airlift/dagster_airlift_tests/unit_tests/conftest.py145CODE
LOW…libraries/dagster-datadog/dagster_datadog/resources.py17CODE
LOW…ries/dagster-celery-k8s/dagster_celery_k8s/launcher.py63CODE
LOW…ries/dagster-celery-k8s/dagster_celery_k8s/executor.py138CODE
LOW…/dagster_rest_resources_tests/api_tests/test_secret.py26CODE
LOW…n_modules/libraries/dagstermill/dagstermill/factory.py381CODE
LOW…les/libraries/dagstermill/dagstermill/asset_factory.py75CODE
LOW…s/libraries/dagster-msteams/dagster_msteams/sensors.py43CODE
LOW…dagster_databricks/databricks_pyspark_step_launcher.py199CODE
LOW…es/dagster-databricks/dagster_databricks/databricks.py249CODE
LOW…es/dagster-databricks/dagster_databricks/databricks.py435CODE
LOW…raries/dagster-fivetran/dagster_fivetran/asset_defs.py230CODE
LOW…raries/dagster-fivetran/dagster_fivetran/asset_defs.py594CODE
LOW…dules/libraries/dagster-slack/dagster_slack/sensors.py91CODE
LOW…es/libraries/dagster-aws/dagster_aws/ssm/parameters.py10CODE
LOW…ries/dagster-aws/dagster_aws/secretsmanager/secrets.py10CODE
LOW…ries/dagster-aws/dagster_aws/s3/compute_log_manager.py77CODE
LOW…_modules/libraries/dagster-aws/dagster_aws/s3/utils.py25CODE
LOW…modules/libraries/dagster-aws/dagster_aws/ecs/tasks.py268CODE
LOW…modules/libraries/dagster-aws/dagster_aws/ecs/tasks.py65CODE
LOW…aries/dagster-aws/dagster_aws/ecs/container_context.py256CODE
LOW…ules/libraries/dagster-aws/dagster_aws/ecs/launcher.py109CODE
LOW…braries/dagster-shared/dagster_shared/serdes/serdes.py245CODE
LOW…braries/dagster-shared/dagster_shared/serdes/serdes.py260CODE
LOW…braries/dagster-shared/dagster_shared/serdes/serdes.py356CODE
LOW…braries/dagster-shared/dagster_shared/serdes/serdes.py153CODE
LOW…ies/dagster-polytomic/dagster_polytomic_tests/utils.py28CODE
144 more matches not shown…
Fake / Example Data145 hits · 166 pts
SeverityFileLineSnippetContext
LOW…/dagster-github/dagster_github_tests/test_resources.py94 "token": "fake_token",CODE
LOW…/dagster-github/dagster_github_tests/test_resources.py144 "token": "fake_token",CODE
LOW…/dagster-github/dagster_github_tests/test_resources.py196 "token": "fake_token",CODE
LOW…/dagster-github/dagster_github_tests/test_resources.py266 "token": "fake_token",CODE
LOW…/dagster-github/dagster_github_tests/test_resources.py332 "token": "fake_token",CODE
LOW…/dagster-github/dagster_github_tests/test_resources.py367 "token": "fake_token",CODE
LOW…ster-cloud-cli/dagster_cloud_cli_tests/test_metrics.py86 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…ster-cloud-cli/dagster_cloud_cli_tests/test_metrics.py194 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py64 monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "some-org:fake-token")STRING
LOW…-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py141 monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "some-org:fake-token")STRING
LOW…-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py330 monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token")STRING
LOW…-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py409 monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token")STRING
LOW…-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py481 monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token")STRING
LOW…-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py526 monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token")STRING
LOW…-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py557 monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token")STRING
LOW…-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py588 monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token")STRING
LOW…-cloud-cli/dagster_cloud_cli_tests/test_ci_commands.py706 monkeypatch.setenv("DAGSTER_CLOUD_API_TOKEN", "fake-token")CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py6FAKE_TOKEN = "fake_token"CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py18 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py54 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py77 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py119 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py154 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py180 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py213 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py236 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py275 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py297 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py324 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…sts/commands/integration/test_atlan_integration_cli.py354 "DAGSTER_CLOUD_API_TOKEN": "fake-token",CODE
LOW…talake/dagster_deltalake_tests/test_metadata_inputs.py19 metadata={"schema": "a_df", "mode": "append", "custom_metadata": {"userName": "John Doe"}}CODE
LOW…talake/dagster_deltalake_tests/test_metadata_inputs.py44 assert last_action["userName"] == "John Doe"CODE
LOW…talake/dagster_deltalake_tests/test_metadata_inputs.py57 custom_metadata={"userName": "John Doe"},CODE
LOW…talake/dagster_deltalake_tests/test_metadata_inputs.py83 assert last_action["userName"] == "John Doe"CODE
LOW…agster_azure_tests/adls2_tests/test_endpoint_suffix.py67 credential=ADLS2SASToken(token="fake-token"),CODE
LOW…agster_azure_tests/adls2_tests/test_endpoint_suffix.py70 mock_create.assert_called_once_with("myaccount", "fake-token", "core.windows.net")CODE
LOW…agster_azure_tests/adls2_tests/test_endpoint_suffix.py76 credential=ADLS2SASToken(token="fake-token"),CODE
LOW…agster_azure_tests/adls2_tests/test_endpoint_suffix.py80 mock_create.assert_called_once_with("myaccount", "fake-token", "core.usgovcloudapi.net")CODE
LOW…agster_azure_tests/adls2_tests/test_endpoint_suffix.py86 credential=ADLS2SASToken(token="fake-token"),CODE
LOW…agster_azure_tests/adls2_tests/test_endpoint_suffix.py90 mock_create.assert_called_once_with("myaccount", "fake-token", "core.usgovcloudapi.net")CODE
LOW…agster_azure_tests/components_tests/test_components.py57 monkeypatch.setenv("AZURE_STORAGE_KEY", "fake-key")CODE
LOW…s/dagster-postgres/dagster_postgres_tests/test_auth.py27 def __init__(self, token: str = "fake-token", ttl: float = 3600) -> None:CODE
LOW…ift_tests/unit_tests/core_tests/test_monitoring_job.py166 tags={REPOSITORY_LABEL_TAG: "placeholder"},CODE
LOW…ift_tests/unit_tests/core_tests/test_monitoring_job.py286 tags={REPOSITORY_LABEL_TAG: "placeholder"},CODE
LOW…ift_tests/unit_tests/core_tests/test_monitoring_job.py370 tags={REPOSITORY_LABEL_TAG: "placeholder"},CODE
LOW…ift_tests/unit_tests/core_tests/test_monitoring_job.py514 tags={REPOSITORY_LABEL_TAG: "placeholder"},CODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py34 fake_token = uuid.uuid4().hexCODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py36 credentials=PowerBIToken(api_token=fake_token),CODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py50 fake_token = uuid.uuid4().hexCODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py52 credentials=PowerBIToken(api_token=fake_token),CODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py64 fake_token = uuid.uuid4().hexCODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py66 credentials=PowerBIToken(api_token=fake_token),CODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py96 fake_token = uuid.uuid4().hexCODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py98 credentials=PowerBIToken(api_token=fake_token),CODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py151 fake_token = uuid.uuid4().hexCODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py153 credentials=PowerBIToken(api_token=fake_token),CODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py212 fake_token = uuid.uuid4().hexCODE
LOW…ster-powerbi/dagster_powerbi_tests/test_asset_specs.py214 credentials=PowerBIToken(api_token=fake_token),CODE
LOW…dagster-powerbi/dagster_powerbi_tests/test_resource.py15 fake_token = uuid.uuid4().hexCODE
LOW…dagster-powerbi/dagster_powerbi_tests/test_resource.py18 credentials=PowerBIToken(api_token=fake_token),CODE
85 more matches not shown…
Redundant / Tautological Comments99 hits · 152 pts
SeverityFileLineSnippetContext
LOW…l/dagster_graphql/implementation/fetch_asset_checks.py171 # Check if we have any subsets to determine the typeCOMMENT
LOW…l_tests/client_tests/test_submit_pipeline_execution.py70 # Check if the op_selection argument is properly passed to the GraphQL queryCOMMENT
LOW…l_tests/client_tests/test_submit_pipeline_execution.py86 # Check if the asset_selection argument is properly passed to the GraphQL queryCOMMENT
LOW…ibraries/dagster-dask/dagster_dask_tests/test_utils.py87 # Set index to ID. We expect the column to be dropped by default.COMMENT
LOW…ibraries/dagster-dask/dagster_dask_tests/test_utils.py95 # Set index to ID without dropping the column.COMMENT
LOW…on_modules/libraries/dagster-k8s/dagster_k8s/client.py156 # Check if the status code is generally whitelistedCOMMENT
LOW…on_modules/libraries/dagster-k8s/dagster_k8s/client.py211 # Check if the status code is generally whitelistedCOMMENT
LOW…es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh259 # Check if aliases need to be updatedCOMMENT
LOW…es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh382 # Check if already installed and get versionCOMMENT
LOW…es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh412 # Check if URL exists and returns valid contentCOMMENT
LOW…es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh424 # Check if any files were extractedCOMMENT
LOW…es/dagster-dbt/dagster_dbt_tests/install_dbt_fusion.sh472 # Check if versions matchCOMMENT
LOW…libraries/dagster-airlift/dagster_airlift/mwaa/auth.py25 # Check if login was succesfullCOMMENT
LOW…unit_tests/in_airflow_tests/test_no_dagster_install.py13 # Check if uv is installedCOMMENT
LOW…agster-airlift/scripts/find_and_replace_in_yaml_dir.sh3# Check if all required arguments are providedCOMMENT
LOW…agster-airlift/scripts/find_and_replace_in_yaml_dir.sh13# Check if the directory existsCOMMENT
LOW…les/libraries/dagster-airlift/scripts/airflow_setup.sh3# Check if the required arguments are providedCOMMENT
LOW…ies/dagster-gcp/dagster_gcp/gcs/compute_log_manager.py86 # Check if the bucket existsCOMMENT
LOW…r-fivetran/dagster_fivetran_tests/test_sensor_dedup.py217 # Set cursor to sync A's timestamp (orchestration already handled it)COMMENT
LOW…dagster-fivetran/dagster_fivetran_tests/test_sensor.py225 # Set cursor to the current succeeded_at so there's no "new" syncCOMMENT
LOW…dules/libraries/dagster-omni/dagster_omni/workspace.py141 # Check if we've received fewer users than requested, indicating we're doneCOMMENT
LOW…dg-cli/dagster_dg_cli/utils/yaml_template_generator.py249 # Check if any anyOf option is a complex object that should be expanded (existing logic)COMMENT
LOW…s/libraries/dagster-dg-cli/dagster_dg_cli/cli/utils.py525 # Check if DAGSTER_HOME is set before proceedingCOMMENT
LOW…raries/dagster-dg-cli/dagster_dg_cli/cli/api/client.py49 # Check if we have a test context with custom factoryCOMMENT
LOW…raries/dagster-dg-cli/dagster_dg_cli/cli/api/shared.py42 # Check if we're in a test contextCOMMENT
LOW…r-dg-cli/dagster_dg_cli/cli/scaffold/branch/command.py194 # Check if we're in a git repository before proceedingCOMMENT
LOW…r-dg-cli/dagster_dg_cli/cli/scaffold/branch/command.py223 # Check if Claude Code SDK and api key are available before proceeding with AI operationsCOMMENT
LOW…s/libraries/dagster-mlflow/dagster_mlflow/resources.py143 # Check if a run with this dagster run id has already been startedCOMMENT
LOW…ableau/dagster_tableau/components/tableau_component.py184 # Check if workbook's project matches by ID or nameCOMMENT
LOW…aries/dagster-shared/dagster_shared/record/__init__.py284 # Add items to lists using replace()STRING
LOW…aries/dagster-shared/dagster_shared/record/__init__.py471 # Add items to lists (use spread operator to avoid mutation)STRING
LOW…ies/dagster-shared/dagster_shared/plus/config_utils.py142 # Check if we're in test mode with DgApiTestContextCOMMENT
LOW…ponents/spark_declarative_pipeline/test_integration.py10# Check if the spark-pipelines CLI is available on the system.COMMENT
LOW…agster_tests/cli_tests/command_tests/test_telemetry.py737 # Set DAGSTER_HOME to a different directoryCOMMENT
LOW…modules/dagster/dagster_tests/utils_tests/test_path.py15 # Check if uv is installedCOMMENT
LOW…/dagster/dagster_tests/asset_defs_tests/test_assets.py2856 # Check if asset_resource is included in regular_asset's required_resource_keysCOMMENT
LOW…/dagster/dagster_tests/asset_defs_tests/test_assets.py2859 # Check if op_resource is included in complex_graph_asset's required_resource_keysCOMMENT
LOWpython_modules/dagster/dagster/_utils/schedules.py979 # Check if this is a DST ambiguous time scenario where both ticksCOMMENT
LOW…/dagster/_core/storage/asset_check_execution_record.py158 # Check if the run is still active, and if not, return the actual status.COMMENT
LOW…ules/dagster/dagster/components/utils/project_paths.py41 # Check if it's a nested config (pyproject.toml) or root (dg.toml)COMMENT
LOW…_modules/dagster/dagster/components/resolved/scopes.py61 # Check if this attribute is whitelistedCOMMENT
LOW…on_modules/dagster/dagster/_vendored/dateutil/rrule.py850 # Output resultsCOMMENT
LOW…s/dagster/dagster/_vendored/dateutil/parser/_parser.py731 # Check if it's a numberCOMMENT
LOW…agster/dagster/_config/pythonic_config/typing_utils.py136 # Check if the annotation is a ResourceDependencyCOMMENT
LOW…dagster-cloud/dagster_cloud/pex/grpc/server/manager.py242 # Set working_directory to "." if it is not set, so that it does notCOMMENT
LOW…loud/dagster_cloud/workspace/config_schema/__init__.py47 # Check if using the legacy format, see below for detailsCOMMENT
LOW…ts/dagster_docs_tests/test_discover_section_headers.py57 # Print resultsCOMMENT
LOW…odules/automation/automation/dagster_docs/validator.py286 # Check if the function has a docstringCOMMENT
LOW…odules/automation/automation/dagster_docs/validator.py390 # Check if this symbol is a top-level exported class with @public annotationCOMMENT
LOW…s/automation/automation/dagster_docs/file_discovery.py123 # Check if file matches any exclude patternCOMMENT
LOW…utomation/automation/dagster_docs/changed_validator.py85 # Check if the object was defined in this moduleCOMMENT
LOW…mation/automation/dagster_docs/public_api_validator.py189 # Check if the node is directly in the module bodyCOMMENT
LOW…mation/automation/dagster_docs/public_api_validator.py202 # Check if it's exported from main dagster moduleCOMMENT
LOW…mation/automation/dagster_docs/public_api_validator.py205 # Check if it's exported from the library's top-levelCOMMENT
LOW…mation/automation/dagster_docs/public_api_validator.py156 # Check if this symbol is exported at top-levelCOMMENT
LOW…mation/automation/dagster_docs/public_api_validator.py223 # Check if it's exported from main dagster moduleCOMMENT
LOW…mation/automation/dagster_docs/public_api_validator.py229 # Check if it's exported from a library top-levelCOMMENT
LOW…mation/automation/dagster_docs/public_api_validator.py382 # Check if @public symbol has RST documentationCOMMENT
LOW…mation/automation/dagster_docs/public_api_validator.py393 # Check if @public symbol is exported at top-levelCOMMENT
LOW…mation/automation/dagster_docs/public_api_validator.py434 # Check if RST documented symbol has @public decoratorCOMMENT
39 more matches not shown…
Modern Structural Boilerplate147 hits · 150 pts
SeverityFileLineSnippetContext
LOW…es/libraries/dagster-github/dagster_github/__init__.py8__all__ = ["GithubResource", "github_resource"]CODE
LOW…ter-snowflake/dagster_snowflake/components/__init__.py3__all__ = [CODE
LOW…ries/dagster-prometheus/dagster_prometheus/__init__.py8__all__ = ["PrometheusResource", "prometheus_resource"]CODE
LOW…_modules/libraries/dagster-dlt/dagster_dlt/__init__.py9__all__ = [CODE
LOW…ibraries/dagster-azure/dagster_azure/pipes/__init__.py5__all__ = [CODE
LOW…/dagster-azure/dagster_azure/pipes/clients/__init__.py3__all__ = [CODE
LOW…es/libraries/dagster-azure/dagster_azure/blob/utils.py41__all__ = [CODE
LOW…s/libraries/dagster-azure/dagster_azure/adls2/utils.py39__all__ = [CODE
LOW…es/libraries/dagster-postgres/dagster_postgres/auth.py10logger = logging.getLogger(__name__)CODE
LOW…ibraries/dagster-postgres/dagster_postgres/__init__.py10__all__ = [CODE
LOW…r-postgres/dagster_postgres/run_storage/run_storage.py214 def set_cursor_values(self, pairs: Mapping[str, str]) -> None:CODE
LOW…on_modules/libraries/dagster-k8s/dagster_k8s/client.py28logger = logging.getLogger(__name__)CODE
LOW…ries/dagster-papertrail/dagster_papertrail/__init__.py8__all__ = ["papertrail_logger"]CODE
LOW…es/libraries/dagster-celery/dagster_celery/__init__.py8__all__ = ["celery_executor"]CODE
LOW…/libraries/dagster-airflow/dagster_airflow/__init__.py30__all__ = [CODE
LOW…/dagster-airflow/dagster_airflow/resources/__init__.py8__all__ = ["make_ephemeral_airflow_db_resource", "make_persistent_airflow_db_resource"]CODE
LOW…dagster-dbt/dagster_dbt/cloud_v2/component/__init__.py5__all__ = ["DbtCloudComponent"]CODE
LOW…ies/dagster-dbt/dagster_dbt_tests/cloud_v2/conftest.py1005def _set_init_load_context() -> None:CODE
LOW…es/libraries/dagster-census/dagster_census/__init__.py11__all__ = [CODE
LOW…odules/libraries/dagster-soda/dagster_soda/__init__.py6__all__ = [CODE
LOW…lift/dagster_airlift/in_airflow/base_asset_operator.py27logger = logging.getLogger(__name__)CODE
LOW…r-airlift/dagster_airlift_tests/unit_tests/conftest.py219def _set_init_load_context() -> None:CODE
LOW…/libraries/dagster-pandera/dagster_pandera/__init__.py323__all__ = [CODE
LOW…/libraries/dagster-datadog/dagster_datadog/__init__.py8__all__ = ["DatadogResource", "datadog_resource"]CODE
LOW…es/libraries/dagster-pandas/dagster_pandas/__init__.py30__all__ = [CODE
LOW…ter-rest-resources/dagster_rest_resources/api/asset.py37logger = logging.getLogger(__name__)CODE
LOW…es/libraries/dagster-twilio/dagster_twilio/__init__.py11__all__ = ["twilio_resource"]CODE
LOW…es/libraries/dagster-gcp/dagster_gcp/pipes/__init__.py5__all__ = [CODE
LOW…ries/dagster-gcp/dagster_gcp/pipes/clients/__init__.py3__all__ = ["PipesDataprocJobClient"]CODE
LOW…braries/dagster-gcp/dagster_gcp/components/__init__.py5__all__ = [CODE
LOW…on_modules/libraries/dagster-ge/dagster_ge/__init__.py8__all__ = ["ge_validation_op_factory"]CODE
LOW…/libraries/dagster-pyspark/dagster_pyspark/__init__.py14__all__ = [CODE
LOW…_modules/libraries/dagster-ssh/dagster_ssh/__init__.py8__all__ = ["SSHResource", "ssh_resource"]CODE
LOW…modules/libraries/dagster-ssh/dagster_ssh/resources.py129 def set_logger(self, logger: logging.Logger) -> None:CODE
LOW…use-polars/dagster_clickhouse_polars_tests/conftest.py17__all__ = ["clickhouse_connection"]CODE
LOW…lickhouse-polars/dagster_clickhouse_polars/__init__.py12__all__ = [CODE
LOW…ules/libraries/dagster-mysql/dagster_mysql/__init__.py10__all__ = ["DagsterMySQLStorage", "MySQLEventLogStorage", "MySQLRunStorage", "MySQLScheduleStorage"]CODE
LOW…dagster-mysql/dagster_mysql/run_storage/run_storage.py179 def set_cursor_values(self, pairs: Mapping[str, str]) -> None:CODE
LOW…/libraries/dagster-datahub/dagster_datahub/__init__.py14__all__ = [CODE
LOW…ules/libraries/dagster-sling/dagster_sling/__init__.py13__all__ = [CODE
LOW…use-pandas/dagster_clickhouse_pandas_tests/conftest.py17__all__ = ["clickhouse_connection"]CODE
LOW…lickhouse-pandas/dagster_clickhouse_pandas/__init__.py12__all__ = [CODE
LOW…dg-cli/dagster_dg_cli/utils/plus/defs_state_storage.py165 def set_latest_version(self, key: str, version: str | None) -> None:STRING
LOW…ries/dagster-dg-cli/dagster_dg_cli/cli/api/__init__.py5__all__ = ["api_group"]CODE
LOW…agster_dg_cli/cli/scaffold/branch/claude/sdk_client.py148 def _update_usage_stats(self, messages: list[Message]) -> None:CODE
LOW…es/libraries/dagster-aws/dagster_aws/pipes/__init__.py21__all__ = [CODE
LOW…ries/dagster-aws/dagster_aws/pipes/clients/__init__.py8__all__ = [CODE
LOW…raries/dagster-hightouch/dagster_hightouch/__init__.py10__all__ = [CODE
LOW…agster-clickhouse/dagster_clickhouse_tests/conftest.py5__all__ = ["clickhouse_connection"]CODE
LOW…ries/dagster-clickhouse/dagster_clickhouse/__init__.py17__all__ = [CODE
LOW…r-clickhouse/dagster_clickhouse/components/__init__.py3__all__ = [CODE
LOW…agster_clickhouse/components/sql_component/__init__.py3__all__ = [CODE
LOW…es/libraries/dagster-dg-core/dagster_dg_core/config.py183def set_config_on_cli_context(cli_context: click.Context, config: "DgRawCliConfig") -> None:CODE
LOW…ries/dagster-dg-core/dagster_dg_core/utils/__init__.py219def set_option_help_output_group(param: click.Parameter, group: str) -> None:CODE
LOW…ries/dagster-dg-core/dagster_dg_core/utils/__init__.py568def set_toml_node(doc: TomlDoc, path: TomlPath, value: object) -> None:CODE
LOW…es/libraries/dagster-mlflow/dagster_mlflow/__init__.py9__all__ = ["end_mlflow_on_run_finished", "mlflow_tracking"]CODE
LOW…s/libraries/dagster-shared/dagster_shared/seven/abc.py20__all__ = [CODE
LOW…ules/libraries/dagster-wandb/dagster_wandb/__init__.py11__all__ = [CODE
LOW…dagster_tests/storage_tests/test_defs_state_storage.py33 def set_latest_version(self, key: str, version: str | None) -> None:CODE
LOW…odules/dagster/dagster_tests/components_tests/utils.py256def set_toml_value(doc: tomlkit.TOMLDocument, path: Iterable[str], value: object) -> None:CODE
87 more matches not shown…
AI Slop Vocabulary71 hits · 133 pts
SeverityFileLineSnippetContext
MEDIUM…/dagster_snowflake/components/dbt_project/component.py1245 # robust, first-class analog of dbt Cloud filtering out its adhoc-job runs.COMMENT
LOW…ster-cloud-cli/dagster_cloud_cli_tests/test_metrics.py211 # For tests, just pass the word "foo" toCOMMENT
MEDIUM…braries/dagster-deltalake/dagster_deltalake/handler.py105 # TODO make robust and move to functionCOMMENT
LOW…braries/dagster-azure/dagster_azure/adls2/resources.py180# config fields in the new resource config. Instead, we'll just use the old config fieldsCOMMENT
MEDIUM…s/dagster-celery/dagster_celery/core_execution_loop.py95 # Certainly yield an engine or job eventCOMMENT
LOW…/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py193 # Since we're only doing this to generate the dependency structure, just use an arbitraryCOMMENT
LOW…/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py212 # However, we can't just use the dependency structure from the latest run, becauseCOMMENT
LOW…/libraries/dagster-dbt/dagster_dbt/cloud/asset_defs.py474 # so we cannot just add our arg as last one to be used and need to removeCOMMENT
LOW…s/libraries/dagster-dbt/dagster_dbt/cloud/resources.py207 # API requires you to supply a bunch of values, so we can just use the current stateCOMMENT
MEDIUMpython_modules/libraries/dagster-airlift/pyproject.toml60# airlift example/tutorial ecosystem (kitchen-sink, perf-harness,COMMENT
LOW…aries/dagster-gcp/dagster_gcp/pipes/message_readers.py132 # just call head object on f"{key_prefix}/1.json" (no need to download it)COMMENT
LOW…n_modules/libraries/dagstermill/dagstermill/factory.py80 # papermill method chooses translator based on kernel_name and language, but we just call theCOMMENT
MEDIUM…ster-databricks/dagster_databricks_tests/test_pipes.py39 # To facilitate using the same script for testing in both the new cluster and existing clusterCOMMENT
MEDIUM…gster_dg_cli_tests/cli_tests/test_scaffold_commands.py99 # Get pydantic version to make test robust across versionsCOMMENT
MEDIUM…gster_dg_cli/cli/scaffold/branch/claude/diagnostics.py242 """Context manager for Claude operations that handles timing and comprehensive logging.STRING
LOW…gster_dg_cli/cli/plus/deploy/configure/configure_ci.py37 # TODO: when we cut over to dg deploy, we'll just use a single build call for the workspaceCOMMENT
MEDIUM…libraries/dagster-aws/dagster_aws/emr/configs_spark.py543 description="""Execution Behavior: If set to true (default), file fetching wCODE
MEDIUM…libraries/dagster-aws/dagster_aws/emr/configs_spark.py726 description="""Shuffle Behavior: (Netty only) Connections betweeCODE
MEDIUM…libraries/dagster-aws/dagster_aws/emr/configs_spark.py762 description="""Shuffle Behavior: Enables the external shuffle seCODE
MEDIUM…libraries/dagster-aws/dagster_aws/emr/configs_spark.py1794 description="""Execution Behavior: If set to true, clones a new Hadoop ConfiCODE
MEDIUM…libraries/dagster-aws/dagster_aws/emr/configs_spark.py2303 description="""Scheduling: Amount of a particular reCODE
MEDIUM…braries/dagster-shared/dagster_shared/serdes/serdes.py1106 # the object_handler for _transform_for_serialization to use in conjunction with json.dumps for iterative serializatCOMMENT
MEDIUM…libraries/dagster-spark/dagster_spark/configs_spark.py543 description="""Execution Behavior: If set to true (default), file fetching wCODE
MEDIUM…libraries/dagster-spark/dagster_spark/configs_spark.py726 description="""Shuffle Behavior: (Netty only) Connections betweeCODE
MEDIUM…libraries/dagster-spark/dagster_spark/configs_spark.py762 description="""Shuffle Behavior: Enables the external shuffle seCODE
MEDIUM…libraries/dagster-spark/dagster_spark/configs_spark.py1794 description="""Execution Behavior: If set to true, clones a new Hadoop ConfiCODE
MEDIUM…libraries/dagster-spark/dagster_spark/configs_spark.py2303 description="""Scheduling: Amount of a particular reCODE
LOW…tion_tests/misc_execution_tests/test_asset_backfill.py336 # Patch the run execution to not actually execute the run, but instead just create itCOMMENT
MEDIUM…sts/definitions_tests/test_definitions_load_context.py205 # no harness-reported name -> NoneCOMMENT
LOW…_defs_tests/asset_graph_view_tests/test_asset_slice.py85 # if asset is removed, don't error just return NoneCOMMENT
MEDIUM…tests/core_tests/resource_tests/test_with_resources.py209 # because io manager def can utilize default.COMMENT
LOW…rce_tests/pythonic_resources/test_direct_invocation.py185 # Here we can just use args for x and y because we're providing the resource explicitly as an argCOMMENT
LOW…e_tests/instance_tests/test_state_storage_lifecycle.py152 # should just set the value to None instead of erroringCOMMENT
LOW…les/dagster/dagster/_utils/caching_instance_queryer.py270 # in the simple case, just use the asset recordCOMMENT
LOW…les/dagster/dagster/_utils/caching_instance_queryer.py413 # then, if the before_cursor is after our latest record's storage id, we can just returnCOMMENT
LOW…dules/dagster/dagster/_core/storage/defs_state/base.py33 # can't reset the token value, so we just set it to NoneCOMMENT
MEDIUM…agster/dagster/_core/execution/context_creation_job.py59 # Essentially, we want to be able to control the timestamp of the log records.COMMENT
LOW…odules/dagster/dagster/_core/execution/plan/objects.py120 # For a redacted error, just return the redacted message without anyCOMMENT
LOW…agster/dagster/_core/instance/methods/asset_methods.py411 # materializable asset and should just return that. If not, we should check for anyCOMMENT
MEDIUM…gster/dagster/_core/executor/child_process_executor.py46 """Inherit from this class in order to use this library.STRING
LOW…core/definitions/automation_tick_evaluation_context.py552 # just use the normal single-partition behaviorCOMMENT
LOW…/_core/definitions/freshness_based_auto_materialize.py135 # if asset will not be materialized, just return the current timeCOMMENT
MEDIUM…/_core/definitions/freshness_based_auto_materialize.py166 """Returns a set of AssetKeyPartitionKeys to materialize in order to abide by the givenSTRING
LOW…gster/_core/definitions/auto_materialize_rule_impls.py126 # if all_partitions is set, then just return all partitions if any ticks have been missedCOMMENT
LOW…gster/_core/definitions/auto_materialize_rule_impls.py133 # for partitions_defs without a time component, just return the last partition if any ticksCOMMENT
MEDIUM…gster/dagster/_core/definitions/asset_daemon_cursor.py175 """This serves as a backcompat layer for deserializing the old cursor format. Will only recoverSTRING
LOW…efinitions/declarative_automation/operands/operands.py211 # if it's the first time evaluating, just return the empty subsetCOMMENT
LOW…efinitions/declarative_automation/operands/operands.py275 # if it's the first time evaluating, just return the empty subsetCOMMENT
LOW…er/_core/definitions/partitions/mapping/time_window.py326 # we can just use these boundaries directly instead of finding nearby boundaries.COMMENT
LOW…ster/_core/definitions/partitions/utils/time_window.py142 # Case where the two don't intersect at all - just return selfCOMMENT
LOW…nitions/partitions/definition/partitions_definition.py115 # in the simple case, simply return the single key in the rangeCOMMENT
LOW…ster/dagster/_core/definitions/partitions/snap/snap.py131 # can't just use a set because we need to preserve ordering.)COMMENT
MEDIUM…nitions/repository_definition/repository_definition.py58 # the name of the code location being loaded, as reported by the loading harnessCOMMENT
MEDIUM…r/_daemon/auto_run_reexecution/auto_run_reexecution.py32 """A more robust method of determining is a run should be retried by the daemon than just lookingSTRING
MEDIUM…ules/dagster/dagster/components/core/component_tree.py83 # for app-managed component discovery when the loading harness does not report theCOMMENT
LOW…on_modules/dagster/dagster/_vendored/dateutil/rrule.py454 # been supplied (the string retrieval will just use .get())COMMENT
MEDIUMpython_modules/dagster/dagster/_config/config_type.py91 """Implement this in order to take a value provided by the userSTRING
MEDIUM…es/dagster/dagster/_config/pythonic_config/resource.py173 """Base class for creating and managing the lifecycle of Dagster resources that utilize structured config.STRING
MEDIUM…es/dagster/dagster/_config/pythonic_config/resource.py598 """Base class for Dagster resources that utilize structured config.STRING
LOW…er/dagster/_config/pythonic_config/conversion_utils.py185 # no FloatSource, so we just return floatCOMMENT
11 more matches not shown…
Hallucination Indicators10 hits · 105 pts
SeverityFileLineSnippetContext
CRITICAL…es/libraries/dagster-azure/dagster_azure/blob/utils.py7 from azure.core.exceptions import ResourceNotFoundErrorCODE
CRITICAL…s/libraries/dagster-azure/dagster_azure/adls2/utils.py7 from azure.core.exceptions import ResourceNotFoundErrorCODE
CRITICAL…dagster-airflow/dagster_airflow_tests/airflow_utils.py29from airflow.utils.helpers import chainCODE
CRITICAL…eline_factory/test_dependency_structure_translation.py10 from airflow.utils.helpers import chainCODE
CRITICAL…braries/dagster-ge/dagster_ge_tests/test_validation.py56 context.resources.pyspark.spark_session.read.format("csv")CODE
CRITICAL…dagster_databricks/databricks_pyspark_step_launcher.py298 self.databricks_runner.client.workspace_client.jobs.cancel_run(databricks_run_id)CODE
CRITICAL…dagster_databricks/databricks_pyspark_step_launcher.py336 run = self.databricks_runner.client.workspace_client.jobs.get_run(CODE
CRITICAL…/dagster-k8s-test-infra/dagster_k8s_test_infra/helm.py575 assert target.spec.template.metadata.labels.get(key) == labels.get(CODE
CRITICALhelm/dagster/schema/schema_tests/test_dagit.py347 assert set(pod_labels.items()).issubset(deployment.spec.template.metadata.labels.items())CODE
CRITICALhelm/dagster/schema/schema_tests/test_dagster_daemon.py510 assert set(pod_labels.items()).issubset(daemon_deployment.spec.template.metadata.labels.items())CODE
Verbosity Indicators53 hits · 103 pts
SeverityFileLineSnippetContext
LOW…ter-rest-resources/dagster_rest_resources/s3_client.py14 # Step 1: Get presigned POST URLCOMMENT
LOW…ter-rest-resources/dagster_rest_resources/s3_client.py23 # Step 2: Upload file to S3 via presigned POSTCOMMENT
LOW…ter-rest-resources/dagster_rest_resources/s3_client.py33 # Step 1: Get presigned GET URLCOMMENT
LOW…ter-rest-resources/dagster_rest_resources/s3_client.py42 # Step 2: Download file from S3COMMENT
LOW…libraries/dagster-omni/dagster_omni_tests/test_defs.py240 # Step 1: Fetch workspace data from "API"COMMENT
LOW…libraries/dagster-omni/dagster_omni_tests/test_defs.py246 # Step 2: Build definitions from workspace dataCOMMENT
LOW…dagster-polytomic/dagster_polytomic_tests/test_defs.py279 # Step 1: Fetch workspace data from "API"COMMENT
LOW…dagster-polytomic/dagster_polytomic_tests/test_defs.py282 # Step 2: Build definitions from workspace dataCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py425 # Step 1: Start with versioned storage, no state availableCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py449 # Step 2: Run the update state job to populate versioned storageCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py453 # Step 3: Reload with versioned storage - should have updated valueCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py464 # Step 4: Switch to local storage - should reset to initial valueCOMMENT
LOW…_backed_component_tests/test_state_backed_component.py488 # Step 5: Load with DAGSTER_IS_DEV_CLI set - should force local refreshCOMMENT
LOW…ons/declarative_automation/operators/since_operator.py139 # Step 1: Add all newly-true trigger partitionsCOMMENT
LOW…ons/declarative_automation/operators/since_operator.py142 # Step 2: Remove all newly-true reset partitionsCOMMENT
LOW…ons/declarative_automation/operators/since_operator.py145 # Step 3: Use TimingMetadata to re-add partitions where trigger fired after resetCOMMENT
LOW…ster/_core/definitions/partitions/utils/time_window.py212 # (don't add it now, because we need to check if it overlaps with the next high pri)COMMENT
LOW…ster/_core/definitions/partitions/utils/time_window.py231 # in the next iteration. (don't add it now, because we need to check if it overlaps with the next high pCOMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py781 # Step 3: Agent is stuck - actual == desired but _grpc_servers has an errorCOMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py786 # Step 4: Next workspace query - server reports no error (hasLoadError=False).COMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py799 # Step 5: Location should be healthy againCOMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py735 # Step 1: Deploy successfullyCOMMENT
LOW…r-cloud/dagster_cloud_tests/test_user_code_launcher.py749 # Step 2: _refresh_actual_entries detects server moved to error state.COMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py200 # Step 0: Auto-prepare if requestedCOMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py204 # Step 1: Verify PR exists (skip if we have context)COMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py212 # Step 2: Update PR titleCOMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py217 # Step 3: Update PR bodyCOMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py222 # Step 4: Update commit messageCOMMENT
LOW…on/automation/dagster_dev/commands/ai_review_update.py232 # Step 5: Display success and Graphite URLCOMMENT
LOW…er_basics_tutorial/src/dagster_tutorial/defs/assets.py1# Step 1: Define the assetsCOMMENT
LOW…er_basics_tutorial/src/dagster_tutorial/defs/assets.py23# Step 2: Define the assets with resourcesCOMMENT
LOW…er_basics_tutorial/src/dagster_tutorial/defs/assets.py93# Step 3: Define assets with dependenciesSTRING
LOW…er_basics_tutorial/src/dagster_tutorial/defs/assets.py131# Step 4: Define asset_checksSTRING
LOW…ry/use_case_repository/guides/snowflake_to_s3_sling.py7# Step 2: Define Sling ConnectionsCOMMENT
LOW…ry/use_case_repository/guides/snowflake_to_s3_sling.py28# Step 3: Define the Data Ingestion AssetCOMMENT
LOW…src/project_mini/defs/dynamic_fanout/dynamic_fanout.py94 # Step 1: Extract processing units from record (10-30 units)COMMENT
LOW…src/project_mini/defs/dynamic_fanout/dynamic_fanout.py98 # Step 2: Process each unit (Second layer of parallelization)COMMENT
LOW…src/project_mini/defs/dynamic_fanout/dynamic_fanout.py108 # Step 3: Aggregate results to create final record outputCOMMENT
LOW…src/project_mini/defs/dynamic_fanout/dynamic_fanout.py140 # Step 1: Extract processing units from record (10-30 units)COMMENT
LOW…src/project_mini/defs/dynamic_fanout/dynamic_fanout.py144 # Step 2: Process each unit (Second layer of parallelization)COMMENT
LOW…src/project_mini/defs/dynamic_fanout/dynamic_fanout.py159 # Step 3: Aggregate results to create final record outputCOMMENT
LOWjs_modules/ui-core/src/gantt/GanttChartLayout.ts38 // Step 1: Place the nodes that have no dependencies into the layout.COMMENT
LOWjs_modules/ui-core/src/gantt/GanttChartLayout.ts53 // Step 2: Recursively iterate through the graph and insert child nodesCOMMENT
LOWjs_modules/ui-core/src/gantt/GanttChartLayout.ts60 // Step 3: Assign X values (pixels) to each box by traversing the graph from theCOMMENT
LOWjs_modules/ui-core/src/gantt/GanttChartLayout.ts80 // Step 4: Assign Y values (row numbers not pixel values)COMMENT
LOWjs_modules/ui-core/src/gantt/toGraphQueryItems.tsx26 // Step 1: Find unresolved steps in the initial plan and build a mappingCOMMENT
LOWjs_modules/ui-core/src/gantt/toGraphQueryItems.tsx53 // Step 2: Create a graph node for each resolved step without any inputs or outputs.COMMENT
LOWjs_modules/ui-core/src/gantt/toGraphQueryItems.tsx67 // Step 3: For each step in the original plan, visit each input and create inputs/outputsCOMMENT
LOW…les/ui-core/src/asset-data/AssetHealthDataProvider.tsx212 // Step 1: Categorize keys based on whether they have definitionsCOMMENT
LOW…les/ui-core/src/asset-data/AssetHealthDataProvider.tsx218 // Step 2: Fetch live data for keys with definitionsCOMMENT
LOW…les/ui-core/src/asset-data/AssetHealthDataProvider.tsx225 // Step 3: Create empty fragments for keys without definitionsCOMMENT
LOW…les/ui-core/src/asset-data/AssetHealthDataProvider.tsx231 // Step 4: Merge live data with empty fragmentsCOMMENT
LOW…les/ui-core/src/asset-data/AssetHealthDataProvider.tsx237 // Step 5: Block trace until data is readyCOMMENT
AI Response Leakage13 hits · 75 pts
SeverityFileLineSnippetContext
HIGH…r_cloud_tests/workspace_tests/ecs_tests/test_client.py334 # In this example, there is a service event that shows unavailable cluster resources.COMMENT
HIGH…cs/docs/integrations/libraries/motherduck/reference.md78{/* TODO fix link A partition must be selected when materializing the above assets, as described in the [Materializing pCODE
HIGH…cs/docs/integrations/libraries/motherduck/reference.md106{/* TODO fix link: A partition must be selected when materializing the above assets, as described in the [Materializing CODE
HIGHdocs/docs/integrations/libraries/snowflake/reference.md104{/* TODO fix link: When materializing the above assets, a partition must be selected, as described in [Materializing parCODE
HIGHdocs/docs/integrations/libraries/snowflake/reference.md132{/* TODO fix link: When materializing the above assets, a partition must be selected, as described in [Materializing parCODE
HIGH…/docs/integrations/libraries/gcp/bigquery/reference.md104When materializing the above assets, a partition must be selected, as described in the [Partitioning assets](/guides/buiCODE
HIGHdocs/docs/integrations/libraries/iceberg/usage.md62 A partition must be selected when materializing the above assets, as described in the [Materializing partitioned assCODE
HIGH…ocs/deployment/dagster-plus/hybrid/kubernetes/setup.md294`envSecrets` will make the secret available in an environment variable, see the Kubernetes docs on [`envFrom` for detailCODE
HIGH…ocs/deployment/dagster-plus/hybrid/kubernetes/setup.md309`env_secrets` will make the secret available in an environment variable, see the Kubernetes docs on [`envFrom` for detaiCODE
HIGH…cs/docs/examples/best-practices/dynamic-vs-parallel.md20[Dynamic outputs](/api/dagster/dynamic#dagster.DynamicOutput) allow you to create separate op executions for each item. CODE
HIGH…/project_dbt/src/project_dbt/analytics/dbt_project.yml30# In this example config, we tell dbt to build all models in the example/COMMENT
HIGH…les/project_fully_featured/dbt_project/dbt_project.yml29# In this example config, we tell dbt to build all models in the example/ directoryCOMMENT
HIGH…ect_analytics/dagster_pypi/dbt_project/dbt_project.yml31# In this example config, we tell dbt to build all models in the example/COMMENT
Overly Generic Function Names70 hits · 71 pts
SeverityFileLineSnippetContext
LOW…aries/dagster-snowflake/dagster_snowflake/resources.py613 def process_data(snowflake: SnowflakeResource):STRING
LOW…ow_tests/test_dagster_job_factory/test_dag_run_conf.py20 def test_function(**kwargs):CODE
LOW…sts/test_persistent_db/test_persistent_airflow_2_db.py37 def test_function(**kwargs):CODE
LOW…sts/test_persistent_db/test_persistent_airflow_2_db.py111 def test_function(**kwargs):CODE
LOW…sts/test_persistent_db/test_persistent_airflow_2_db.py166 def test_function(**kwargs):CODE
LOW…sts/test_persistent_db/test_persistent_airflow_2_db.py272 def test_function(**kwargs):CODE
LOW…tests/test_persistent_db/test_persistent_airflow_db.py34 def test_function(**kwargs):CODE
LOW…tests/test_persistent_db/test_persistent_airflow_db.py110 def test_function(**kwargs):CODE
LOW…tests/test_persistent_db/test_persistent_airflow_db.py158 def test_function(**kwargs):CODE
LOW…libraries/dagster-databricks/dagster_databricks/ops.py85 def do_stuff():STRING
LOW…libraries/dagster-databricks/dagster_databricks/ops.py192 def do_stuff():STRING
LOW…dagster-aws/dagster_aws_tests/ecs_tests/stubbed_ecs.py364 def run_task(self, **kwargs):CODE
LOW…er_aws_tests/ecs_tests/launcher_tests/test_failures.py7 def run_task(self=ecs, **kwargs):CODE
LOW…er_aws_tests/ecs_tests/launcher_tests/test_failures.py53 def run_task(*args, **kwargs):CODE
LOW…er_aws_tests/ecs_tests/launcher_tests/test_failures.py92 def run_task(*args, **kwargs):CODE
LOW…er_aws_tests/ecs_tests/launcher_tests/test_failures.py128 def run_task(self, **_kwargs):CODE
LOW…/dagster-aws/dagster_aws_tests/pipes_tests/fake_ecs.py67 def run_task(self, **kwargs):CODE
LOW…/dagster-aws/dagster_aws_tests/pipes_tests/test_ecs.py265 def run_task(self, **kwargs):CODE
LOW…s/execution_tests/misc_execution_tests/test_retries.py725def do_something(my_resource: FailOnceResource):CODE
LOW…agster_tests/definitions_tests/test_reconstructable.py57def test_function():CODE
LOW…/dagster_tests/definitions_tests/test_sensor_result.py8def do_something():CODE
LOW…_tests/definitions_tests/test_repository_definition.py1562 def do_something():CODE
LOW…er/dagster_tests/general_tests/grpc_tests/grpc_repo.py8def do_something():CODE
LOW…_tests/general_tests/utils_tests/test_cached_method.py23 def my_method(self, arg1) -> tuple:CODE
LOW…_tests/general_tests/utils_tests/test_cached_method.py46 def my_method(self, arg1, arg2) -> tuple:CODE
LOW…_tests/general_tests/utils_tests/test_cached_method.py65 def my_method(self, _arg1: LeakTestKey) -> LeakTestValue:CODE
LOW…_tests/general_tests/utils_tests/test_cached_method.py149 async def my_method(self, arg1) -> tuple:CODE
LOW…er/dagster_tests/cli_tests/command_tests/extra_repo.py5def do_something():CODE
LOW…ter_tests/cli_tests/command_tests/test_cli_commands.py32def do_something():CODE
LOW…ules/dagster/dagster_tests/api_tests/api_tests_repo.py11def do_something():CODE
LOW…agster_tests/api_tests/test_api_snapshot_repository.py94def do_something():CODE
LOW…/dagster/dagster_tests/asset_defs_tests/test_assets.py1701 def my_function():CODE
LOW…gster/dagster_tests/asset_defs_tests/test_asset_job.py1471 def do_something(x):CODE
LOW…dagster_tests/core_tests/test_mask_user_code_errors.py235 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…/core_tests/resource_tests/test_resource_parameters.py198 def do_something(self):CODE
LOW…s/resource_tests/pythonic_resources/test_configured.py18 def do_something(my_resource: MyResource) -> str:CODE
LOW…s/resource_tests/pythonic_resources/test_configured.py43 def do_something(my_resource: MyResource) -> str:CODE
LOW…s/resource_tests/pythonic_resources/test_configured.py78 def do_something(my_resource: MyResource) -> str:CODE
LOW…s/resource_tests/pythonic_resources/test_configured.py144 def do_something(my_resource: MyResource) -> str:CODE
LOW…s/resource_tests/pythonic_resources/test_configured.py167 def do_something(my_resource: MyResource) -> str:CODE
LOW…_tests/core_tests/pythonic_config_tests/test_graphs.py14 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…_tests/core_tests/pythonic_config_tests/test_graphs.py31 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…_tests/core_tests/pythonic_config_tests/test_graphs.py65 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…_tests/core_tests/pythonic_config_tests/test_graphs.py92 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…_tests/core_tests/pythonic_config_tests/test_graphs.py121 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…_tests/core_tests/pythonic_config_tests/test_graphs.py146 def do_something(config: DoSomethingConfig) -> MyEnum:CODE
LOW…_tests/core_tests/pythonic_config_tests/test_graphs.py174 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…ts/core_tests/pythonic_config_tests/test_configured.py13 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…ts/core_tests/pythonic_config_tests/test_configured.py42 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…ts/core_tests/pythonic_config_tests/test_configured.py71 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…ts/core_tests/pythonic_config_tests/test_configured.py93 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…s/core_tests/pythonic_config_tests/test_jobs_graphs.py14 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…s/core_tests/pythonic_config_tests/test_jobs_graphs.py31 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…s/core_tests/pythonic_config_tests/test_jobs_graphs.py58 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…s/core_tests/pythonic_config_tests/test_jobs_graphs.py87 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…s/core_tests/pythonic_config_tests/test_jobs_graphs.py112 def do_something(config: DoSomethingConfig) -> MyEnum:CODE
LOW…s/core_tests/pythonic_config_tests/test_jobs_graphs.py140 def do_something(config: DoSomethingConfig) -> str:CODE
LOW…ter/dagster_tests/core_tests/graph_tests/test_graph.py145 def do_stuff(context):CODE
LOW…ter/dagster_tests/core_tests/graph_tests/test_graph.py180 def do_stuff(context):CODE
LOW…_core/definitions/decorators/source_asset_decorator.py254 def my_function():STRING
10 more matches not shown…
Slop Phrases18 hits · 28 pts
SeverityFileLineSnippetContext
LOW…es/dagster-airbyte/dagster_airbyte/legacy_resources.py246 # if Airbyte sync has not completed, make sure to cancel it so that it doesn't outliveCOMMENT
LOW…es/dagster-airbyte/dagster_airbyte/legacy_resources.py629 # if Airbyte sync has not completed, make sure to cancel it so that it doesn't outliveCOMMENT
LOW…libraries/dagster-airbyte/dagster_airbyte/resources.py453 # if Airbyte sync has not completed, make sure to cancel it so that it doesn't outliveCOMMENT
LOW…libraries/dagster-tableau/dagster_tableau/resources.py342 # if any Tableau syncs have not completed, make sure to cancel them so they don't outliveCOMMENT
LOW…es/dagster-shared/dagster_shared/telemetry/__init__.py114 # last action, we need to make sure to re-create the directoryCOMMENT
MEDIUM…_defs/pythonic_components/relative_import/component.py9 """A simple component class for demonstration purposes."""STRING
MEDIUM…finitions/both_python_defs_and_components/top_level.py9 """A simple component class for demonstration purposes."""STRING
MEDIUM…_names_at_levels/folder_with_component_py/component.py6 """A simple component class for demonstration purposes."""STRING
LOW…ative_automation_tests/scenario_utils/base_scenario.py236 # make sure to log the planned eventsCOMMENT
LOWpython_modules/dagster/dagster/_core/execution/api.py687 # If you have repository_load_data, make sure to use it when building planCOMMENT
LOW…hon_modules/dagster/dagster/_core/definitions/input.py103 # when adding new params, make sure to update combine_with_inferred and with_dagster_type belowCOMMENT
LOW…ore/definitions/assets/definition/assets_definition.py155 # if adding new fields, make sure to handle them in the with_attributes, from_graph,COMMENT
LOWpython_modules/dagster/dagster/_daemon/asset_daemon.py1037 # make sure to override the evaluation id to stay on the previous valueCOMMENT
MEDIUM…egrations/powerbi-component/6-populated-component.yaml11 # Alternatively, you can use an API access tokenCOMMENT
MEDIUM…ides/components/integrations/test_powerbi_component.py129 # Alternatively, you can use an API access tokenSTRING
MEDIUMhelm/dagster/values.yaml927 # If your Redis connection needs configuration options, you can use this field to specific theCOMMENT
LOWhelm/dagster/values.yaml56 # Defines the port where the webserver will serve requests; if changed, don't forget to update theCOMMENT
LOWhelm/dagster/values.yaml56 # Defines the port where the webserver will serve requests; if changed, don't forget to update theCOMMENT
Dead Code9 hits · 18 pts
SeverityFileLineSnippetContext
MEDIUM…s/libraries/dagster-cloud-cli/dagster_cloud_cli/gql.py833CODE
MEDIUM…dagster_tests/storage_tests/test_instigation_logger.py26CODE
MEDIUM…dagster/dagster_tests/storage_tests/test_io_manager.py488CODE
MEDIUM…tion_tests/execution_plan_tests/test_execution_plan.py505CODE
MEDIUM…dagster/dagster_tests/core_tests/test_job_execution.py969CODE
MEDIUM…r/dagster_tests/core_tests/hook_tests/test_hook_run.py299CODE
MEDIUMpython_modules/dagster/dagster/_generate/generate.py48CODE
MEDIUM…suites/daemon-test-suite/test_dagster_daemon_health.py114CODE
MEDIUM…project_snowflake_dynamic_tables/tests/test_sensors.py60CODE
Synthetic Comment Markers2 hits · 8 pts
SeverityFileLineSnippetContext
HIGH…-dg-cli/dagster_dg_cli/cli/scaffold/branch/planning.py29 markdown_content: The complete plan as markdown text generated by ClaudeSTRING
HIGH…ples/docs_projects/project_dspy/dspy_modules/puzzle.py292 test_set = shuffled # Test on all puzzles as requestedCODE
Magic Placeholder Names1 hit · 5 pts
SeverityFileLineSnippetContext
HIGH…les/docs_snippets/docs_snippets/integrations/qdrant.py29 api_key="<your-api-key>",CODE
TODO Padding3 hits · 4 pts
SeverityFileLineSnippetContext
LOW…ibraries/dagster-gcp/dagster_gcp/dataproc/resources.py72 # TODO: Add loggingCOMMENT
LOW…ibraries/dagster-gcp/dagster_gcp/dataproc/resources.py107 # TODO: Add logging here print('Waiting for job ID {} to finish...'.format(job_id))COMMENT
LOW…dagster-cloud/dagster_cloud/execution/utils/process.py18 # TODO: implement cross platform process checkCOMMENT
Example Usage Blocks2 hits · 3 pts
SeverityFileLineSnippetContext
LOW…/components_tests/scaffoldable_tests/test_decorator.py7# Example usage:COMMENT
LOW…_modules/dagster-cloud/dagster_cloud_tests/conftest.py54 # Usage:COMMENT