diff --git a/js_modules/dagster-ui/packages/ui-core/src/graphql/possibleTypes.generated.json b/js_modules/dagster-ui/packages/ui-core/src/graphql/possibleTypes.generated.json index 11ac02518e077..a809c08388c95 100644 --- a/js_modules/dagster-ui/packages/ui-core/src/graphql/possibleTypes.generated.json +++ b/js_modules/dagster-ui/packages/ui-core/src/graphql/possibleTypes.generated.json @@ -1 +1 @@ -{"DisplayableEvent":["EngineEvent","ExecutionStepOutputEvent","ExpectationResult","FailureMetadata","HandledOutputEvent","LoadedInputEvent","ObjectStoreOperationResult","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","StepWorkerStartedEvent","StepWorkerStartingEvent","MaterializationEvent","ObservationEvent","TypeCheck"],"MarkerEvent":["EngineEvent","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","StepWorkerStartedEvent","StepWorkerStartingEvent"],"ErrorEvent":["EngineEvent","ExecutionStepFailureEvent","ExecutionStepUpForRetryEvent","HookErroredEvent","RunCanceledEvent","RunFailureEvent","ResourceInitFailureEvent"],"MessageEvent":["EngineEvent","ExecutionStepFailureEvent","ExecutionStepInputEvent","ExecutionStepOutputEvent","ExecutionStepRestartEvent","ExecutionStepSkippedEvent","ExecutionStepStartEvent","ExecutionStepSuccessEvent","ExecutionStepUpForRetryEvent","HandledOutputEvent","HookCompletedEvent","HookErroredEvent","HookSkippedEvent","LoadedInputEvent","LogMessageEvent","ObjectStoreOperationEvent","RunCanceledEvent","RunCancelingEvent","RunDequeuedEvent","RunEnqueuedEvent","RunFailureEvent","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","RunStartEvent","RunStartingEvent","RunSuccessEvent","StepExpectationResultEvent","StepWorkerStartedEvent","StepWorkerStartingEvent","MaterializationEvent","ObservationEvent","AssetMaterializationPlannedEvent","LogsCapturedEvent","AlertStartEvent","AlertSuccessEvent","AlertFailureEvent","AssetCheckEvaluationPlannedEvent","AssetCheckEvaluationEvent"],"RunEvent":["RunCanceledEvent","RunCancelingEvent","RunDequeuedEvent","RunEnqueuedEvent","RunFailureEvent","RunStartEvent","RunStartingEvent","RunSuccessEvent","AssetMaterializationPlannedEvent","AlertStartEvent","AlertSuccessEvent","AlertFailureEvent"],"PipelineRunStepStats":["RunStepStats"],"StepEvent":["EngineEvent","ExecutionStepFailureEvent","ExecutionStepInputEvent","ExecutionStepOutputEvent","ExecutionStepRestartEvent","ExecutionStepSkippedEvent","ExecutionStepStartEvent","ExecutionStepSuccessEvent","ExecutionStepUpForRetryEvent","HandledOutputEvent","HookCompletedEvent","HookErroredEvent","HookSkippedEvent","LoadedInputEvent","ObjectStoreOperationEvent","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","StepExpectationResultEvent","StepWorkerStartedEvent","StepWorkerStartingEvent","MaterializationEvent","ObservationEvent","AssetCheckEvaluationPlannedEvent","AssetCheckEvaluationEvent"],"AssetOwner":["UserAssetOwner","TeamAssetOwner"],"AssetPartitionStatuses":["DefaultPartitionStatuses","MultiPartitionStatuses","TimePartitionStatuses"],"PartitionStatus1D":["TimePartitionStatuses","DefaultPartitionStatuses"],"AssetChecksOrError":["AssetChecks","AssetCheckNeedsMigrationError","AssetCheckNeedsUserCodeUpgrade","AssetCheckNeedsAgentUpgradeError"],"Instigator":["Schedule","Sensor"],"EvaluationStackEntry":["EvaluationStackListItemEntry","EvaluationStackPathEntry","EvaluationStackMapKeyEntry","EvaluationStackMapValueEntry"],"IPipelineSnapshot":["Pipeline","PipelineSnapshot","Job"],"PipelineConfigValidationError":["FieldNotDefinedConfigError","FieldsNotDefinedConfigError","MissingFieldConfigError","MissingFieldsConfigError","RuntimeMismatchConfigError","SelectorTypeConfigError"],"PipelineConfigValidationInvalid":["RunConfigValidationInvalid"],"PipelineConfigValidationResult":["InvalidSubsetError","PipelineConfigValidationValid","RunConfigValidationInvalid","PipelineNotFoundError","PythonError"],"PipelineReference":["PipelineSnapshot","UnknownPipeline"],"PipelineRun":["Run"],"DagsterRunEvent":["ExecutionStepFailureEvent","ExecutionStepInputEvent","ExecutionStepOutputEvent","ExecutionStepSkippedEvent","ExecutionStepStartEvent","ExecutionStepSuccessEvent","ExecutionStepUpForRetryEvent","ExecutionStepRestartEvent","LogMessageEvent","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","RunFailureEvent","RunStartEvent","RunEnqueuedEvent","RunDequeuedEvent","RunStartingEvent","RunCancelingEvent","RunCanceledEvent","RunSuccessEvent","StepWorkerStartedEvent","StepWorkerStartingEvent","HandledOutputEvent","LoadedInputEvent","LogsCapturedEvent","ObjectStoreOperationEvent","StepExpectationResultEvent","MaterializationEvent","ObservationEvent","EngineEvent","HookCompletedEvent","HookSkippedEvent","HookErroredEvent","AlertStartEvent","AlertSuccessEvent","AlertFailureEvent","AssetMaterializationPlannedEvent","AssetCheckEvaluationPlannedEvent","AssetCheckEvaluationEvent"],"PipelineRunLogsSubscriptionPayload":["PipelineRunLogsSubscriptionSuccess","PipelineRunLogsSubscriptionFailure"],"RunOrError":["Run","RunNotFoundError","PythonError"],"PipelineRunStatsSnapshot":["RunStatsSnapshot"],"RunStatsSnapshotOrError":["RunStatsSnapshot","PythonError"],"PipelineSnapshotOrError":["PipelineNotFoundError","PipelineSnapshot","PipelineSnapshotNotFoundError","PythonError"],"AssetOrError":["Asset","AssetNotFoundError"],"AssetsOrError":["AssetConnection","PythonError"],"DeletePipelineRunResult":["DeletePipelineRunSuccess","UnauthorizedError","PythonError","RunNotFoundError"],"ExecutionPlanOrError":["ExecutionPlan","RunConfigValidationInvalid","PipelineNotFoundError","InvalidSubsetError","PythonError"],"PipelineOrError":["Pipeline","PipelineNotFoundError","InvalidSubsetError","PythonError"],"ReloadRepositoryLocationMutationResult":["WorkspaceLocationEntry","ReloadNotSupported","RepositoryLocationNotFound","UnauthorizedError","PythonError"],"RepositoryLocationOrLoadError":["RepositoryLocation","PythonError"],"ReloadWorkspaceMutationResult":["Workspace","UnauthorizedError","PythonError"],"ShutdownRepositoryLocationMutationResult":["ShutdownRepositoryLocationSuccess","RepositoryLocationNotFound","UnauthorizedError","PythonError"],"TerminatePipelineExecutionFailure":["TerminateRunFailure"],"TerminatePipelineExecutionSuccess":["TerminateRunSuccess"],"TerminateRunResult":["TerminateRunSuccess","TerminateRunFailure","RunNotFoundError","UnauthorizedError","PythonError"],"ScheduleMutationResult":["PythonError","UnauthorizedError","ScheduleStateResult"],"ScheduleOrError":["Schedule","ScheduleNotFoundError","PythonError"],"SchedulerOrError":["Scheduler","SchedulerNotDefinedError","PythonError"],"SchedulesOrError":["Schedules","RepositoryNotFoundError","PythonError"],"ScheduleTickSpecificData":["ScheduleTickSuccessData","ScheduleTickFailureData"],"LaunchBackfillResult":["LaunchBackfillSuccess","PartitionSetNotFoundError","InvalidStepError","InvalidOutputError","RunConfigValidationInvalid","PipelineNotFoundError","RunConflict","UnauthorizedError","PythonError","InvalidSubsetError","PresetNotFoundError","ConflictingExecutionParamsError","NoModeProvidedError"],"ConfigTypeOrError":["EnumConfigType","CompositeConfigType","RegularConfigType","PipelineNotFoundError","ConfigTypeNotFoundError","PythonError"],"ConfigType":["ArrayConfigType","CompositeConfigType","EnumConfigType","NullableConfigType","RegularConfigType","ScalarUnionConfigType","MapConfigType"],"WrappingConfigType":["ArrayConfigType","NullableConfigType"],"DagsterType":["ListDagsterType","NullableDagsterType","RegularDagsterType"],"DagsterTypeOrError":["RegularDagsterType","PipelineNotFoundError","DagsterTypeNotFoundError","PythonError"],"WrappingDagsterType":["ListDagsterType","NullableDagsterType"],"Error":["AssetCheckNeedsMigrationError","AssetCheckNeedsUserCodeUpgrade","AssetCheckNeedsAgentUpgradeError","AssetNotFoundError","ConflictingExecutionParamsError","ConfigTypeNotFoundError","DagsterTypeNotFoundError","InvalidPipelineRunsFilterError","InvalidSubsetError","ModeNotFoundError","NoModeProvidedError","PartitionSetNotFoundError","PipelineNotFoundError","RunConflict","PipelineSnapshotNotFoundError","PresetNotFoundError","PythonError","ErrorChainLink","UnauthorizedError","ReloadNotSupported","RepositoryLocationNotFound","RepositoryNotFoundError","ResourceNotFoundError","RunGroupNotFoundError","RunNotFoundError","ScheduleNotFoundError","SchedulerNotDefinedError","SensorNotFoundError","UnsupportedOperationError","DuplicateDynamicPartitionError","InstigationStateNotFoundError","SolidStepStatusUnavailableError","GraphNotFoundError","BackfillNotFoundError","PartitionSubsetDeserializationError","AutoMaterializeAssetEvaluationNeedsMigrationError"],"PipelineRunConflict":["RunConflict"],"PipelineRunNotFoundError":["RunNotFoundError"],"RepositoriesOrError":["RepositoryConnection","RepositoryNotFoundError","PythonError"],"RepositoryOrError":["PythonError","Repository","RepositoryNotFoundError"],"WorkspaceLocationEntryOrError":["WorkspaceLocationEntry","PythonError"],"InstigationTypeSpecificData":["SensorData","ScheduleData"],"InstigationStateOrError":["InstigationState","InstigationStateNotFoundError","PythonError"],"InstigationStatesOrError":["InstigationStates","PythonError"],"MetadataEntry":["TableColumnLineageMetadataEntry","TableSchemaMetadataEntry","TableMetadataEntry","FloatMetadataEntry","IntMetadataEntry","JsonMetadataEntry","BoolMetadataEntry","MarkdownMetadataEntry","PathMetadataEntry","NotebookMetadataEntry","PythonArtifactMetadataEntry","TextMetadataEntry","UrlMetadataEntry","PipelineRunMetadataEntry","AssetMetadataEntry","JobMetadataEntry","CodeReferencesMetadataEntry","NullMetadataEntry","TimestampMetadataEntry"],"SourceLocation":["LocalFileCodeReference","UrlCodeReference"],"PartitionRunConfigOrError":["PartitionRunConfig","PythonError"],"AssetBackfillStatus":["AssetPartitionsStatusCounts","UnpartitionedAssetStatus"],"PartitionSetOrError":["PartitionSet","PartitionSetNotFoundError","PythonError"],"PartitionSetsOrError":["PartitionSets","PipelineNotFoundError","PythonError"],"PartitionsOrError":["Partitions","PythonError"],"PartitionStatusesOrError":["PartitionStatuses","PythonError"],"PartitionTagsOrError":["PartitionTags","PythonError"],"RunConfigSchemaOrError":["RunConfigSchema","PipelineNotFoundError","InvalidSubsetError","ModeNotFoundError","PythonError"],"LaunchRunResult":["LaunchRunSuccess","InvalidStepError","InvalidOutputError","RunConfigValidationInvalid","PipelineNotFoundError","RunConflict","UnauthorizedError","PythonError","InvalidSubsetError","PresetNotFoundError","ConflictingExecutionParamsError","NoModeProvidedError"],"LaunchRunReexecutionResult":["LaunchRunSuccess","InvalidStepError","InvalidOutputError","RunConfigValidationInvalid","PipelineNotFoundError","RunConflict","UnauthorizedError","PythonError","InvalidSubsetError","PresetNotFoundError","ConflictingExecutionParamsError","NoModeProvidedError"],"LaunchPipelineRunSuccess":["LaunchRunSuccess"],"RunsOrError":["Runs","InvalidPipelineRunsFilterError","PythonError"],"PipelineRuns":["Runs"],"RunGroupOrError":["RunGroup","RunGroupNotFoundError","PythonError"],"SensorOrError":["Sensor","SensorNotFoundError","UnauthorizedError","PythonError"],"SensorsOrError":["Sensors","RepositoryNotFoundError","PythonError"],"StopSensorMutationResultOrError":["StopSensorMutationResult","UnauthorizedError","PythonError"],"ISolidDefinition":["CompositeSolidDefinition","SolidDefinition"],"SolidContainer":["Pipeline","PipelineSnapshot","Job","CompositeSolidDefinition","Graph"],"SolidStepStatsOrError":["SolidStepStatsConnection","SolidStepStatusUnavailableError"],"WorkspaceOrError":["Workspace","PythonError"],"WorkspaceLocationStatusEntriesOrError":["WorkspaceLocationStatusEntries","PythonError"],"GraphOrError":["Graph","GraphNotFoundError","PythonError"],"ResourceDetailsOrError":["ResourceDetails","ResourceNotFoundError","PythonError"],"ResourcesOrError":["ResourceDetailsList","RepositoryNotFoundError","PythonError"],"EnvVarWithConsumersOrError":["EnvVarWithConsumersList","PythonError"],"RunTagKeysOrError":["PythonError","RunTagKeys"],"RunTagsOrError":["PythonError","RunTags"],"RunIdsOrError":["RunIds","InvalidPipelineRunsFilterError","PythonError"],"AssetNodeOrError":["AssetNode","AssetNotFoundError"],"PartitionBackfillOrError":["PartitionBackfill","BackfillNotFoundError","PythonError"],"PartitionBackfillsOrError":["PartitionBackfills","PythonError"],"EventConnectionOrError":["EventConnection","RunNotFoundError","PythonError"],"AutoMaterializeAssetEvaluationRecordsOrError":["AutoMaterializeAssetEvaluationRecords","AutoMaterializeAssetEvaluationNeedsMigrationError"],"PartitionKeysOrError":["PartitionKeys","PartitionSubsetDeserializationError"],"AutoMaterializeRuleEvaluationData":["TextRuleEvaluationData","ParentMaterializedRuleEvaluationData","WaitingOnKeysRuleEvaluationData"],"AssetConditionEvaluationNode":["UnpartitionedAssetConditionEvaluationNode","PartitionedAssetConditionEvaluationNode","SpecificPartitionAssetConditionEvaluationNode"],"AssetConditionEvaluationRecordsOrError":["AssetConditionEvaluationRecords","AutoMaterializeAssetEvaluationNeedsMigrationError"],"SensorDryRunResult":["PythonError","SensorNotFoundError","DryRunInstigationTick"],"ScheduleDryRunResult":["DryRunInstigationTick","PythonError","ScheduleNotFoundError"],"TerminateRunsResultOrError":["TerminateRunsResult","PythonError"],"AssetWipeMutationResult":["AssetNotFoundError","UnauthorizedError","PythonError","UnsupportedOperationError","AssetWipeSuccess"],"ReportRunlessAssetEventsResult":["UnauthorizedError","PythonError","ReportRunlessAssetEventsSuccess"],"ResumeBackfillResult":["ResumeBackfillSuccess","UnauthorizedError","PythonError"],"CancelBackfillResult":["CancelBackfillSuccess","UnauthorizedError","PythonError"],"LogTelemetryMutationResult":["LogTelemetrySuccess","PythonError"],"AddDynamicPartitionResult":["AddDynamicPartitionSuccess","UnauthorizedError","PythonError","DuplicateDynamicPartitionError"],"DeleteDynamicPartitionsResult":["DeleteDynamicPartitionsSuccess","UnauthorizedError","PythonError"]} \ No newline at end of file +{"DisplayableEvent":["EngineEvent","ExecutionStepOutputEvent","ExpectationResult","FailureMetadata","HandledOutputEvent","LoadedInputEvent","ObjectStoreOperationResult","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","StepWorkerStartedEvent","StepWorkerStartingEvent","MaterializationEvent","ObservationEvent","TypeCheck"],"MarkerEvent":["EngineEvent","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","StepWorkerStartedEvent","StepWorkerStartingEvent"],"ErrorEvent":["EngineEvent","ExecutionStepFailureEvent","ExecutionStepUpForRetryEvent","HookErroredEvent","RunCanceledEvent","RunFailureEvent","ResourceInitFailureEvent"],"MessageEvent":["EngineEvent","ExecutionStepFailureEvent","ExecutionStepInputEvent","ExecutionStepOutputEvent","ExecutionStepRestartEvent","ExecutionStepSkippedEvent","ExecutionStepStartEvent","ExecutionStepSuccessEvent","ExecutionStepUpForRetryEvent","HandledOutputEvent","HookCompletedEvent","HookErroredEvent","HookSkippedEvent","LoadedInputEvent","LogMessageEvent","ObjectStoreOperationEvent","RunCanceledEvent","RunCancelingEvent","RunDequeuedEvent","RunEnqueuedEvent","RunFailureEvent","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","RunStartEvent","RunStartingEvent","RunSuccessEvent","StepExpectationResultEvent","StepWorkerStartedEvent","StepWorkerStartingEvent","MaterializationEvent","ObservationEvent","AssetMaterializationPlannedEvent","LogsCapturedEvent","AlertStartEvent","AlertSuccessEvent","AlertFailureEvent","AssetCheckEvaluationPlannedEvent","AssetCheckEvaluationEvent"],"RunEvent":["RunCanceledEvent","RunCancelingEvent","RunDequeuedEvent","RunEnqueuedEvent","RunFailureEvent","RunStartEvent","RunStartingEvent","RunSuccessEvent","AssetMaterializationPlannedEvent","AlertStartEvent","AlertSuccessEvent","AlertFailureEvent"],"PipelineRunStepStats":["RunStepStats"],"StepEvent":["EngineEvent","ExecutionStepFailureEvent","ExecutionStepInputEvent","ExecutionStepOutputEvent","ExecutionStepRestartEvent","ExecutionStepSkippedEvent","ExecutionStepStartEvent","ExecutionStepSuccessEvent","ExecutionStepUpForRetryEvent","HandledOutputEvent","HookCompletedEvent","HookErroredEvent","HookSkippedEvent","LoadedInputEvent","ObjectStoreOperationEvent","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","StepExpectationResultEvent","StepWorkerStartedEvent","StepWorkerStartingEvent","MaterializationEvent","ObservationEvent","AssetCheckEvaluationPlannedEvent","AssetCheckEvaluationEvent"],"AssetOwner":["UserAssetOwner","TeamAssetOwner"],"AssetPartitionStatuses":["DefaultPartitionStatuses","MultiPartitionStatuses","TimePartitionStatuses"],"PartitionStatus1D":["TimePartitionStatuses","DefaultPartitionStatuses"],"AssetChecksOrError":["AssetChecks","AssetCheckNeedsMigrationError","AssetCheckNeedsUserCodeUpgrade","AssetCheckNeedsAgentUpgradeError"],"Instigator":["Schedule","Sensor"],"EvaluationStackEntry":["EvaluationStackListItemEntry","EvaluationStackPathEntry","EvaluationStackMapKeyEntry","EvaluationStackMapValueEntry"],"IPipelineSnapshot":["Pipeline","PipelineSnapshot","Job"],"PipelineConfigValidationError":["FieldNotDefinedConfigError","FieldsNotDefinedConfigError","MissingFieldConfigError","MissingFieldsConfigError","RuntimeMismatchConfigError","SelectorTypeConfigError"],"PipelineConfigValidationInvalid":["RunConfigValidationInvalid"],"PipelineConfigValidationResult":["InvalidSubsetError","PipelineConfigValidationValid","RunConfigValidationInvalid","PipelineNotFoundError","PythonError"],"PipelineReference":["PipelineSnapshot","UnknownPipeline"],"PipelineRun":["Run"],"DagsterRunEvent":["ExecutionStepFailureEvent","ExecutionStepInputEvent","ExecutionStepOutputEvent","ExecutionStepSkippedEvent","ExecutionStepStartEvent","ExecutionStepSuccessEvent","ExecutionStepUpForRetryEvent","ExecutionStepRestartEvent","LogMessageEvent","ResourceInitFailureEvent","ResourceInitStartedEvent","ResourceInitSuccessEvent","RunFailureEvent","RunStartEvent","RunEnqueuedEvent","RunDequeuedEvent","RunStartingEvent","RunCancelingEvent","RunCanceledEvent","RunSuccessEvent","StepWorkerStartedEvent","StepWorkerStartingEvent","HandledOutputEvent","LoadedInputEvent","LogsCapturedEvent","ObjectStoreOperationEvent","StepExpectationResultEvent","MaterializationEvent","ObservationEvent","EngineEvent","HookCompletedEvent","HookSkippedEvent","HookErroredEvent","AlertStartEvent","AlertSuccessEvent","AlertFailureEvent","AssetMaterializationPlannedEvent","AssetCheckEvaluationPlannedEvent","AssetCheckEvaluationEvent"],"PipelineRunLogsSubscriptionPayload":["PipelineRunLogsSubscriptionSuccess","PipelineRunLogsSubscriptionFailure"],"RunOrError":["Run","RunNotFoundError","PythonError"],"PipelineRunStatsSnapshot":["RunStatsSnapshot"],"RunStatsSnapshotOrError":["RunStatsSnapshot","PythonError"],"PipelineSnapshotOrError":["PipelineNotFoundError","PipelineSnapshot","PipelineSnapshotNotFoundError","PythonError"],"MegaRun":["Run","PartitionBackfill"],"AssetOrError":["Asset","AssetNotFoundError"],"AssetsOrError":["AssetConnection","PythonError"],"DeletePipelineRunResult":["DeletePipelineRunSuccess","UnauthorizedError","PythonError","RunNotFoundError"],"ExecutionPlanOrError":["ExecutionPlan","RunConfigValidationInvalid","PipelineNotFoundError","InvalidSubsetError","PythonError"],"PipelineOrError":["Pipeline","PipelineNotFoundError","InvalidSubsetError","PythonError"],"ReloadRepositoryLocationMutationResult":["WorkspaceLocationEntry","ReloadNotSupported","RepositoryLocationNotFound","UnauthorizedError","PythonError"],"RepositoryLocationOrLoadError":["RepositoryLocation","PythonError"],"ReloadWorkspaceMutationResult":["Workspace","UnauthorizedError","PythonError"],"ShutdownRepositoryLocationMutationResult":["ShutdownRepositoryLocationSuccess","RepositoryLocationNotFound","UnauthorizedError","PythonError"],"TerminatePipelineExecutionFailure":["TerminateRunFailure"],"TerminatePipelineExecutionSuccess":["TerminateRunSuccess"],"TerminateRunResult":["TerminateRunSuccess","TerminateRunFailure","RunNotFoundError","UnauthorizedError","PythonError"],"ScheduleMutationResult":["PythonError","UnauthorizedError","ScheduleStateResult"],"ScheduleOrError":["Schedule","ScheduleNotFoundError","PythonError"],"SchedulerOrError":["Scheduler","SchedulerNotDefinedError","PythonError"],"SchedulesOrError":["Schedules","RepositoryNotFoundError","PythonError"],"ScheduleTickSpecificData":["ScheduleTickSuccessData","ScheduleTickFailureData"],"LaunchBackfillResult":["LaunchBackfillSuccess","PartitionSetNotFoundError","InvalidStepError","InvalidOutputError","RunConfigValidationInvalid","PipelineNotFoundError","RunConflict","UnauthorizedError","PythonError","InvalidSubsetError","PresetNotFoundError","ConflictingExecutionParamsError","NoModeProvidedError"],"ConfigTypeOrError":["EnumConfigType","CompositeConfigType","RegularConfigType","PipelineNotFoundError","ConfigTypeNotFoundError","PythonError"],"ConfigType":["ArrayConfigType","CompositeConfigType","EnumConfigType","NullableConfigType","RegularConfigType","ScalarUnionConfigType","MapConfigType"],"WrappingConfigType":["ArrayConfigType","NullableConfigType"],"DagsterType":["ListDagsterType","NullableDagsterType","RegularDagsterType"],"DagsterTypeOrError":["RegularDagsterType","PipelineNotFoundError","DagsterTypeNotFoundError","PythonError"],"WrappingDagsterType":["ListDagsterType","NullableDagsterType"],"Error":["AssetCheckNeedsMigrationError","AssetCheckNeedsUserCodeUpgrade","AssetCheckNeedsAgentUpgradeError","AssetNotFoundError","ConflictingExecutionParamsError","ConfigTypeNotFoundError","DagsterTypeNotFoundError","InvalidPipelineRunsFilterError","InvalidSubsetError","ModeNotFoundError","NoModeProvidedError","PartitionSetNotFoundError","PipelineNotFoundError","RunConflict","PipelineSnapshotNotFoundError","PresetNotFoundError","PythonError","ErrorChainLink","UnauthorizedError","ReloadNotSupported","RepositoryLocationNotFound","RepositoryNotFoundError","ResourceNotFoundError","RunGroupNotFoundError","RunNotFoundError","ScheduleNotFoundError","SchedulerNotDefinedError","SensorNotFoundError","UnsupportedOperationError","DuplicateDynamicPartitionError","InstigationStateNotFoundError","SolidStepStatusUnavailableError","GraphNotFoundError","BackfillNotFoundError","PartitionSubsetDeserializationError","AutoMaterializeAssetEvaluationNeedsMigrationError"],"PipelineRunConflict":["RunConflict"],"PipelineRunNotFoundError":["RunNotFoundError"],"RepositoriesOrError":["RepositoryConnection","RepositoryNotFoundError","PythonError"],"RepositoryOrError":["PythonError","Repository","RepositoryNotFoundError"],"WorkspaceLocationEntryOrError":["WorkspaceLocationEntry","PythonError"],"InstigationTypeSpecificData":["SensorData","ScheduleData"],"InstigationStateOrError":["InstigationState","InstigationStateNotFoundError","PythonError"],"InstigationStatesOrError":["InstigationStates","PythonError"],"MetadataEntry":["TableColumnLineageMetadataEntry","TableSchemaMetadataEntry","TableMetadataEntry","FloatMetadataEntry","IntMetadataEntry","JsonMetadataEntry","BoolMetadataEntry","MarkdownMetadataEntry","PathMetadataEntry","NotebookMetadataEntry","PythonArtifactMetadataEntry","TextMetadataEntry","UrlMetadataEntry","PipelineRunMetadataEntry","AssetMetadataEntry","JobMetadataEntry","CodeReferencesMetadataEntry","NullMetadataEntry","TimestampMetadataEntry"],"SourceLocation":["LocalFileCodeReference","UrlCodeReference"],"PartitionRunConfigOrError":["PartitionRunConfig","PythonError"],"AssetBackfillStatus":["AssetPartitionsStatusCounts","UnpartitionedAssetStatus"],"PartitionSetOrError":["PartitionSet","PartitionSetNotFoundError","PythonError"],"PartitionSetsOrError":["PartitionSets","PipelineNotFoundError","PythonError"],"PartitionsOrError":["Partitions","PythonError"],"PartitionStatusesOrError":["PartitionStatuses","PythonError"],"PartitionTagsOrError":["PartitionTags","PythonError"],"RunConfigSchemaOrError":["RunConfigSchema","PipelineNotFoundError","InvalidSubsetError","ModeNotFoundError","PythonError"],"LaunchRunResult":["LaunchRunSuccess","InvalidStepError","InvalidOutputError","RunConfigValidationInvalid","PipelineNotFoundError","RunConflict","UnauthorizedError","PythonError","InvalidSubsetError","PresetNotFoundError","ConflictingExecutionParamsError","NoModeProvidedError"],"LaunchRunReexecutionResult":["LaunchRunSuccess","InvalidStepError","InvalidOutputError","RunConfigValidationInvalid","PipelineNotFoundError","RunConflict","UnauthorizedError","PythonError","InvalidSubsetError","PresetNotFoundError","ConflictingExecutionParamsError","NoModeProvidedError"],"LaunchPipelineRunSuccess":["LaunchRunSuccess"],"RunsOrError":["Runs","InvalidPipelineRunsFilterError","PythonError"],"PipelineRuns":["Runs"],"RunGroupOrError":["RunGroup","RunGroupNotFoundError","PythonError"],"SensorOrError":["Sensor","SensorNotFoundError","UnauthorizedError","PythonError"],"SensorsOrError":["Sensors","RepositoryNotFoundError","PythonError"],"StopSensorMutationResultOrError":["StopSensorMutationResult","UnauthorizedError","PythonError"],"ISolidDefinition":["CompositeSolidDefinition","SolidDefinition"],"SolidContainer":["Pipeline","PipelineSnapshot","Job","CompositeSolidDefinition","Graph"],"SolidStepStatsOrError":["SolidStepStatsConnection","SolidStepStatusUnavailableError"],"WorkspaceOrError":["Workspace","PythonError"],"WorkspaceLocationStatusEntriesOrError":["WorkspaceLocationStatusEntries","PythonError"],"GraphOrError":["Graph","GraphNotFoundError","PythonError"],"ResourceDetailsOrError":["ResourceDetails","ResourceNotFoundError","PythonError"],"ResourcesOrError":["ResourceDetailsList","RepositoryNotFoundError","PythonError"],"EnvVarWithConsumersOrError":["EnvVarWithConsumersList","PythonError"],"MegaRunsOrError":["MegaRuns","InvalidPipelineRunsFilterError","PythonError"],"RunTagKeysOrError":["PythonError","RunTagKeys"],"RunTagsOrError":["PythonError","RunTags"],"RunIdsOrError":["RunIds","InvalidPipelineRunsFilterError","PythonError"],"AssetNodeOrError":["AssetNode","AssetNotFoundError"],"PartitionBackfillOrError":["PartitionBackfill","BackfillNotFoundError","PythonError"],"PartitionBackfillsOrError":["PartitionBackfills","PythonError"],"EventConnectionOrError":["EventConnection","RunNotFoundError","PythonError"],"AutoMaterializeAssetEvaluationRecordsOrError":["AutoMaterializeAssetEvaluationRecords","AutoMaterializeAssetEvaluationNeedsMigrationError"],"PartitionKeysOrError":["PartitionKeys","PartitionSubsetDeserializationError"],"AutoMaterializeRuleEvaluationData":["TextRuleEvaluationData","ParentMaterializedRuleEvaluationData","WaitingOnKeysRuleEvaluationData"],"AssetConditionEvaluationNode":["UnpartitionedAssetConditionEvaluationNode","PartitionedAssetConditionEvaluationNode","SpecificPartitionAssetConditionEvaluationNode"],"AssetConditionEvaluationRecordsOrError":["AssetConditionEvaluationRecords","AutoMaterializeAssetEvaluationNeedsMigrationError"],"SensorDryRunResult":["PythonError","SensorNotFoundError","DryRunInstigationTick"],"ScheduleDryRunResult":["DryRunInstigationTick","PythonError","ScheduleNotFoundError"],"TerminateRunsResultOrError":["TerminateRunsResult","PythonError"],"AssetWipeMutationResult":["AssetNotFoundError","UnauthorizedError","PythonError","UnsupportedOperationError","AssetWipeSuccess"],"ReportRunlessAssetEventsResult":["UnauthorizedError","PythonError","ReportRunlessAssetEventsSuccess"],"ResumeBackfillResult":["ResumeBackfillSuccess","UnauthorizedError","PythonError"],"CancelBackfillResult":["CancelBackfillSuccess","UnauthorizedError","PythonError"],"LogTelemetryMutationResult":["LogTelemetrySuccess","PythonError"],"AddDynamicPartitionResult":["AddDynamicPartitionSuccess","UnauthorizedError","PythonError","DuplicateDynamicPartitionError"],"DeleteDynamicPartitionsResult":["DeleteDynamicPartitionsSuccess","UnauthorizedError","PythonError"]} \ No newline at end of file diff --git a/js_modules/dagster-ui/packages/ui-core/src/graphql/types.ts b/js_modules/dagster-ui/packages/ui-core/src/graphql/types.ts index 7e3c67b94e759..dedca0ca14258 100644 --- a/js_modules/dagster-ui/packages/ui-core/src/graphql/types.ts +++ b/js_modules/dagster-ui/packages/ui-core/src/graphql/types.ts @@ -2527,6 +2527,38 @@ export type MaterializedPartitionRangeStatuses2D = { secondaryDim: PartitionStatus1D; }; +export type MegaRun = { + assetCheckSelection: Maybe>; + assetSelection: Maybe>; + creationTime: Scalars['Float']['output']; + endTime: Maybe; + jobName: Maybe; + runId: Scalars['String']['output']; + runStatus: Maybe; + runType: MegaRunType; + startTime: Maybe; + tags: Array; +}; + +export enum MegaRunType { + BACKFILL = 'BACKFILL', + RUN = 'RUN', +} + +export type MegaRuns = { + __typename: 'MegaRuns'; + results: MegaRunsConnection; +}; + +export type MegaRunsConnection = { + __typename: 'MegaRunsConnection'; + cursor: Scalars['String']['output']; + hasMore: Scalars['Boolean']['output']; + results: Array; +}; + +export type MegaRunsOrError = InvalidPipelineRunsFilterError | MegaRuns | PythonError; + export type MessageEvent = { eventType: Maybe; level: LogLevel; @@ -3056,12 +3088,15 @@ export type PartitionRunsArgs = { limit?: InputMaybe; }; -export type PartitionBackfill = { +export type PartitionBackfill = MegaRun & { __typename: 'PartitionBackfill'; assetBackfillData: Maybe; + assetCheckSelection: Maybe>; assetSelection: Maybe>; cancelableRuns: Array; + creationTime: Scalars['Float']['output']; description: Maybe; + endTime: Maybe; endTimestamp: Maybe; error: Maybe; fromFailure: Scalars['Boolean']['output']; @@ -3070,6 +3105,7 @@ export type PartitionBackfill = { id: Scalars['String']['output']; isAssetBackfill: Scalars['Boolean']['output']; isValidSerialization: Scalars['Boolean']['output']; + jobName: Maybe; logEvents: InstigationEventConnection; numCancelable: Scalars['Int']['output']; numPartitions: Maybe; @@ -3080,7 +3116,11 @@ export type PartitionBackfill = { partitionStatuses: Maybe; partitionsTargetedForAssetKey: Maybe; reexecutionSteps: Maybe>; + runId: Scalars['String']['output']; + runStatus: RunStatus; + runType: MegaRunType; runs: Array; + startTime: Maybe; status: BulkActionStatus; tags: Array; timestamp: Scalars['Float']['output']; @@ -3692,6 +3732,7 @@ export type Query = { isPipelineConfigValid: PipelineConfigValidationResult; locationStatusesOrError: WorkspaceLocationStatusEntriesOrError; logsForRun: EventConnectionOrError; + megaRunsOrError: MegaRunsOrError; partitionBackfillOrError: PartitionBackfillOrError; partitionBackfillsOrError: PartitionBackfillsOrError; partitionSetOrError: PartitionSetOrError; @@ -3849,6 +3890,11 @@ export type QueryLogsForRunArgs = { runId: Scalars['ID']['input']; }; +export type QueryMegaRunsOrErrorArgs = { + cursor?: InputMaybe; + limit?: InputMaybe; +}; + export type QueryPartitionBackfillOrErrorArgs = { backfillId: Scalars['String']['input']; }; @@ -4355,47 +4401,50 @@ export type ResumeBackfillSuccess = { backfillId: Scalars['String']['output']; }; -export type Run = PipelineRun & { - __typename: 'Run'; - assetCheckSelection: Maybe>; - assetMaterializations: Array; - assetSelection: Maybe>; - assets: Array; - canTerminate: Scalars['Boolean']['output']; - capturedLogs: CapturedLogs; - creationTime: Scalars['Float']['output']; - endTime: Maybe; - eventConnection: EventConnection; - executionPlan: Maybe; - hasConcurrencyKeySlots: Scalars['Boolean']['output']; - hasDeletePermission: Scalars['Boolean']['output']; - hasReExecutePermission: Scalars['Boolean']['output']; - hasTerminatePermission: Scalars['Boolean']['output']; - hasUnconstrainedRootNodes: Scalars['Boolean']['output']; - id: Scalars['ID']['output']; - jobName: Scalars['String']['output']; - mode: Scalars['String']['output']; - parentPipelineSnapshotId: Maybe; - parentRunId: Maybe; - pipeline: PipelineSnapshot | UnknownPipeline; - pipelineName: Scalars['String']['output']; - pipelineSnapshotId: Maybe; - repositoryOrigin: Maybe; - resolvedOpSelection: Maybe>; - rootConcurrencyKeys: Maybe>; - rootRunId: Maybe; - runConfig: Scalars['RunConfigData']['output']; - runConfigYaml: Scalars['String']['output']; - runId: Scalars['String']['output']; - solidSelection: Maybe>; - startTime: Maybe; - stats: RunStatsSnapshotOrError; - status: RunStatus; - stepKeysToExecute: Maybe>; - stepStats: Array; - tags: Array; - updateTime: Maybe; -}; +export type Run = MegaRun & + PipelineRun & { + __typename: 'Run'; + assetCheckSelection: Maybe>; + assetMaterializations: Array; + assetSelection: Maybe>; + assets: Array; + canTerminate: Scalars['Boolean']['output']; + capturedLogs: CapturedLogs; + creationTime: Scalars['Float']['output']; + endTime: Maybe; + eventConnection: EventConnection; + executionPlan: Maybe; + hasConcurrencyKeySlots: Scalars['Boolean']['output']; + hasDeletePermission: Scalars['Boolean']['output']; + hasReExecutePermission: Scalars['Boolean']['output']; + hasTerminatePermission: Scalars['Boolean']['output']; + hasUnconstrainedRootNodes: Scalars['Boolean']['output']; + id: Scalars['ID']['output']; + jobName: Scalars['String']['output']; + mode: Scalars['String']['output']; + parentPipelineSnapshotId: Maybe; + parentRunId: Maybe; + pipeline: PipelineSnapshot | UnknownPipeline; + pipelineName: Scalars['String']['output']; + pipelineSnapshotId: Maybe; + repositoryOrigin: Maybe; + resolvedOpSelection: Maybe>; + rootConcurrencyKeys: Maybe>; + rootRunId: Maybe; + runConfig: Scalars['RunConfigData']['output']; + runConfigYaml: Scalars['String']['output']; + runId: Scalars['String']['output']; + runStatus: RunStatus; + runType: MegaRunType; + solidSelection: Maybe>; + startTime: Maybe; + stats: RunStatsSnapshotOrError; + status: RunStatus; + stepKeysToExecute: Maybe>; + stepStats: Array; + tags: Array; + updateTime: Maybe; + }; export type RunCapturedLogsArgs = { fileKey: Scalars['String']['input']; @@ -9829,6 +9878,67 @@ export const buildMaterializedPartitionRangeStatuses2D = ( }; }; +export const buildMegaRun = ( + overrides?: Partial, + _relationshipsToOmit: Set = new Set(), +): {__typename: 'MegaRun'} & MegaRun => { + const relationshipsToOmit: Set = new Set(_relationshipsToOmit); + relationshipsToOmit.add('MegaRun'); + return { + __typename: 'MegaRun', + assetCheckSelection: + overrides && overrides.hasOwnProperty('assetCheckSelection') + ? overrides.assetCheckSelection! + : [], + assetSelection: + overrides && overrides.hasOwnProperty('assetSelection') ? overrides.assetSelection! : [], + creationTime: + overrides && overrides.hasOwnProperty('creationTime') ? overrides.creationTime! : 1.1, + endTime: overrides && overrides.hasOwnProperty('endTime') ? overrides.endTime! : 2.59, + jobName: overrides && overrides.hasOwnProperty('jobName') ? overrides.jobName! : 'rerum', + runId: overrides && overrides.hasOwnProperty('runId') ? overrides.runId! : 'nesciunt', + runStatus: + overrides && overrides.hasOwnProperty('runStatus') + ? overrides.runStatus! + : RunStatus.CANCELED, + runType: + overrides && overrides.hasOwnProperty('runType') ? overrides.runType! : MegaRunType.BACKFILL, + startTime: overrides && overrides.hasOwnProperty('startTime') ? overrides.startTime! : 7.11, + tags: overrides && overrides.hasOwnProperty('tags') ? overrides.tags! : [], + }; +}; + +export const buildMegaRuns = ( + overrides?: Partial, + _relationshipsToOmit: Set = new Set(), +): {__typename: 'MegaRuns'} & MegaRuns => { + const relationshipsToOmit: Set = new Set(_relationshipsToOmit); + relationshipsToOmit.add('MegaRuns'); + return { + __typename: 'MegaRuns', + results: + overrides && overrides.hasOwnProperty('results') + ? overrides.results! + : relationshipsToOmit.has('MegaRunsConnection') + ? ({} as MegaRunsConnection) + : buildMegaRunsConnection({}, relationshipsToOmit), + }; +}; + +export const buildMegaRunsConnection = ( + overrides?: Partial, + _relationshipsToOmit: Set = new Set(), +): {__typename: 'MegaRunsConnection'} & MegaRunsConnection => { + const relationshipsToOmit: Set = new Set(_relationshipsToOmit); + relationshipsToOmit.add('MegaRunsConnection'); + return { + __typename: 'MegaRunsConnection', + cursor: overrides && overrides.hasOwnProperty('cursor') ? overrides.cursor! : 'tempore', + hasMore: overrides && overrides.hasOwnProperty('hasMore') ? overrides.hasMore! : true, + results: overrides && overrides.hasOwnProperty('results') ? overrides.results! : [], + }; +}; + export const buildMessageEvent = ( overrides?: Partial, _relationshipsToOmit: Set = new Set(), @@ -10654,14 +10764,21 @@ export const buildPartitionBackfill = ( : relationshipsToOmit.has('AssetBackfillData') ? ({} as AssetBackfillData) : buildAssetBackfillData({}, relationshipsToOmit), + assetCheckSelection: + overrides && overrides.hasOwnProperty('assetCheckSelection') + ? overrides.assetCheckSelection! + : [], assetSelection: overrides && overrides.hasOwnProperty('assetSelection') ? overrides.assetSelection! : [], cancelableRuns: overrides && overrides.hasOwnProperty('cancelableRuns') ? overrides.cancelableRuns! : [], + creationTime: + overrides && overrides.hasOwnProperty('creationTime') ? overrides.creationTime! : 1.18, description: overrides && overrides.hasOwnProperty('description') ? overrides.description! : 'reprehenderit', + endTime: overrides && overrides.hasOwnProperty('endTime') ? overrides.endTime! : 4.91, endTimestamp: overrides && overrides.hasOwnProperty('endTimestamp') ? overrides.endTimestamp! : 0.33, error: @@ -10687,6 +10804,7 @@ export const buildPartitionBackfill = ( overrides && overrides.hasOwnProperty('isValidSerialization') ? overrides.isValidSerialization! : false, + jobName: overrides && overrides.hasOwnProperty('jobName') ? overrides.jobName! : 'est', logEvents: overrides && overrides.hasOwnProperty('logEvents') ? overrides.logEvents! @@ -10727,7 +10845,15 @@ export const buildPartitionBackfill = ( : buildAssetBackfillTargetPartitions({}, relationshipsToOmit), reexecutionSteps: overrides && overrides.hasOwnProperty('reexecutionSteps') ? overrides.reexecutionSteps! : [], + runId: overrides && overrides.hasOwnProperty('runId') ? overrides.runId! : 'eligendi', + runStatus: + overrides && overrides.hasOwnProperty('runStatus') + ? overrides.runStatus! + : RunStatus.CANCELED, + runType: + overrides && overrides.hasOwnProperty('runType') ? overrides.runType! : MegaRunType.BACKFILL, runs: overrides && overrides.hasOwnProperty('runs') ? overrides.runs! : [], + startTime: overrides && overrides.hasOwnProperty('startTime') ? overrides.startTime! : 9.35, status: overrides && overrides.hasOwnProperty('status') ? overrides.status! @@ -11913,6 +12039,12 @@ export const buildQuery = ( : relationshipsToOmit.has('EventConnection') ? ({} as EventConnection) : buildEventConnection({}, relationshipsToOmit), + megaRunsOrError: + overrides && overrides.hasOwnProperty('megaRunsOrError') + ? overrides.megaRunsOrError! + : relationshipsToOmit.has('InvalidPipelineRunsFilterError') + ? ({} as InvalidPipelineRunsFilterError) + : buildInvalidPipelineRunsFilterError({}, relationshipsToOmit), partitionBackfillOrError: overrides && overrides.hasOwnProperty('partitionBackfillOrError') ? overrides.partitionBackfillOrError! @@ -12840,6 +12972,12 @@ export const buildRun = ( runConfigYaml: overrides && overrides.hasOwnProperty('runConfigYaml') ? overrides.runConfigYaml! : 'eveniet', runId: overrides && overrides.hasOwnProperty('runId') ? overrides.runId! : 'fuga', + runStatus: + overrides && overrides.hasOwnProperty('runStatus') + ? overrides.runStatus! + : RunStatus.CANCELED, + runType: + overrides && overrides.hasOwnProperty('runType') ? overrides.runType! : MegaRunType.BACKFILL, solidSelection: overrides && overrides.hasOwnProperty('solidSelection') ? overrides.solidSelection! : [], startTime: overrides && overrides.hasOwnProperty('startTime') ? overrides.startTime! : 2.52, diff --git a/python_modules/dagster-graphql/dagster_graphql/implementation/fetch_runs.py b/python_modules/dagster-graphql/dagster_graphql/implementation/fetch_runs.py index b696b00c52fa3..b743163d21639 100644 --- a/python_modules/dagster-graphql/dagster_graphql/implementation/fetch_runs.py +++ b/python_modules/dagster-graphql/dagster_graphql/implementation/fetch_runs.py @@ -456,7 +456,9 @@ def get_mega_runs( instance, cursor=mega_run_cursor.run_cursor, limit=fetch_limit ) - if fetch_limit: + if ( + fetch_limit and limit + ): # if fetch_limit is non-None then limit must also be non-None, but check for pyright # if we fetched limit+1 of either runs or backfills, we know there must be more results # to fetch on the next call since we will return limit results for this call. Additionally, # if we fetched more than limit of runs and backfill combined, we know there are more results diff --git a/python_modules/dagster-graphql/dagster_graphql/schema/backfill.py b/python_modules/dagster-graphql/dagster_graphql/schema/backfill.py index ff4bdd1332b45..c6797af151807 100644 --- a/python_modules/dagster-graphql/dagster_graphql/schema/backfill.py +++ b/python_modules/dagster-graphql/dagster_graphql/schema/backfill.py @@ -123,7 +123,7 @@ class GrapheneBulkActionStatus(graphene.Enum): class Meta: name = "BulkActionStatus" - def to_dagster_run_status(self) -> GrapheneRunStatus: + def to_dagster_run_status(self): """Placeholder for this PR. Will do a more thurough pass to accurately convert backfill status to DagsterRunStatus in a stacked branch. """ diff --git a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_mega_run.py b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_mega_run.py index 2ab2f50a15996..f42f0bde66bb5 100644 --- a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_mega_run.py +++ b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_mega_run.py @@ -46,9 +46,14 @@ } } } - """ +# when runs are inserted into the database, sqlite uses CURRENT_TIMESTAMP to set the creation time. +# CURRENT_TIMESTAMP only has second precision for sqlite, so if we create runs and backfills without any delay +# the resulting list is a chunk of runs and then a chunk of backfills when ordered by time. Adding a small +# delay between creating a run and a backfill makes the resulting list more interwoven +CREATE_DELAY = 0.5 + def _create_run(graphql_context) -> DagsterRun: return create_run_for_test( @@ -83,7 +88,7 @@ class TestMegaRuns(ExecutingGraphQLContextTestMatrix): def test_get_mega_runs(self, graphql_context): for _ in range(10): _create_run(graphql_context) - time.sleep(1) + time.sleep(CREATE_DELAY) _create_backfill(graphql_context) result = execute_dagster_graphql( @@ -129,7 +134,7 @@ def test_get_mega_runs(self, graphql_context): def test_get_mega_runs_ignores_backfill_runs(self, graphql_context): for _ in range(10): _create_run_for_backfill(graphql_context, backfill_id="foo") - time.sleep(1) + time.sleep(CREATE_DELAY) _create_backfill(graphql_context) result = execute_dagster_graphql( @@ -157,7 +162,7 @@ def test_get_mega_runs_ignores_backfill_runs(self, graphql_context): def test_get_mega_runs_inexact_limit(self, graphql_context): for _ in range(10): _create_run(graphql_context) - time.sleep(1) + time.sleep(CREATE_DELAY) _create_backfill(graphql_context) result = execute_dagster_graphql( @@ -218,7 +223,7 @@ def test_get_mega_runs_no_runs_or_backfills_exist(self, graphql_context): def test_get_mega_runs_cursor_respected(self, graphql_context): for _ in range(10): _create_run(graphql_context) - time.sleep(1) + time.sleep(CREATE_DELAY) _create_backfill(graphql_context) result = execute_dagster_graphql( @@ -272,7 +277,7 @@ def test_get_mega_runs_cursor_respected(self, graphql_context): def test_get_mega_runs_one_backfill_long_ago(self, graphql_context): backfill_id = _create_backfill(graphql_context) - time.sleep(2) # to ensure that all runs are more recent than the backfill + time.sleep(1) # to ensure that all runs are more recent than the backfill for _ in range(15): _create_run(graphql_context) @@ -336,7 +341,7 @@ def test_get_mega_runs_one_new_backfill(self, graphql_context): for _ in range(15): _create_run(graphql_context) - time.sleep(2) # to ensure that all runs are older than the backfill + time.sleep(1) # to ensure that all runs are older than the backfill backfill_id = _create_backfill(graphql_context) result = execute_dagster_graphql(