package api

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc Ping (PingRequest, PingReply)

  dagster_api.proto:8

• rpc Heartbeat (PingRequest, PingReply)

  dagster_api.proto:9

• rpc StreamingPing (StreamingPingRequest, stream StreamingPingEvent)

  dagster_api.proto:10

  message StreamingPingRequest

  dagster_api.proto:47

  • int32 sequence_length = 1

  • string echo = 2

  message StreamingPingEvent

  dagster_api.proto:52

  • int32 sequence_number = 1

  • string echo = 2

• rpc GetServerId (Empty, GetServerIdReply)

  dagster_api.proto:11

  message GetServerIdReply

  dagster_api.proto:57

  • string server_id = 1

• rpc ExecutionPlanSnapshot (ExecutionPlanSnapshotRequest, ExecutionPlanSnapshotReply)

  dagster_api.proto:12

  message ExecutionPlanSnapshotRequest

  dagster_api.proto:61

  • string serialized_execution_plan_snapshot_args = 1

  message ExecutionPlanSnapshotReply

  dagster_api.proto:65

  • string serialized_execution_plan_snapshot = 1

• rpc ListRepositories (ListRepositoriesRequest, ListRepositoriesReply)

  dagster_api.proto:13

  message ListRepositoriesRequest

  dagster_api.proto:105

  (message has no fields)

  message ListRepositoriesReply

  dagster_api.proto:108

  • string serialized_list_repositories_response_or_error = 1

• rpc ExternalPartitionNames (ExternalPartitionNamesRequest, ExternalPartitionNamesReply)

  dagster_api.proto:14

  message ExternalPartitionNamesRequest

  dagster_api.proto:69

  • string serialized_partition_names_args = 1

  message ExternalPartitionNamesReply

  dagster_api.proto:73

  • string serialized_external_partition_names_or_external_partition_execution_error = 1

• rpc ExternalNotebookData (ExternalNotebookDataRequest, ExternalNotebookDataReply)

  dagster_api.proto:15

  message ExternalNotebookDataRequest

  dagster_api.proto:77

  • string notebook_path = 1

  message ExternalNotebookDataReply

  dagster_api.proto:81

  • bytes content = 1

• rpc ExternalPartitionConfig (ExternalPartitionConfigRequest, ExternalPartitionConfigReply)

  dagster_api.proto:16

  message ExternalPartitionConfigRequest

  dagster_api.proto:85

  • string serialized_partition_args = 1

  message ExternalPartitionConfigReply

  dagster_api.proto:89

  • string serialized_external_partition_config_or_external_partition_execution_error = 1

• rpc ExternalPartitionTags (ExternalPartitionTagsRequest, ExternalPartitionTagsReply)

  dagster_api.proto:17

  message ExternalPartitionTagsRequest

  dagster_api.proto:93

  • string serialized_partition_args = 1

  message ExternalPartitionTagsReply

  dagster_api.proto:97

  • string serialized_external_partition_tags_or_external_partition_execution_error = 1

• rpc ExternalPartitionSetExecutionParams (ExternalPartitionSetExecutionParamsRequest, stream StreamingChunkEvent)

  dagster_api.proto:18

  message ExternalPartitionSetExecutionParamsRequest

  dagster_api.proto:101

  • string serialized_partition_set_execution_param_args = 1

• rpc ExternalPipelineSubsetSnapshot (ExternalPipelineSubsetSnapshotRequest, ExternalPipelineSubsetSnapshotReply)

  dagster_api.proto:19

  message ExternalPipelineSubsetSnapshotRequest

  dagster_api.proto:112

  • string serialized_pipeline_subset_snapshot_args = 1

  message ExternalPipelineSubsetSnapshotReply

  dagster_api.proto:116

  • string serialized_external_pipeline_subset_result = 1

• rpc ExternalRepository (ExternalRepositoryRequest, ExternalRepositoryReply)

  dagster_api.proto:20

  message ExternalRepositoryReply

  dagster_api.proto:125

  • string serialized_external_repository_data = 1

• rpc ExternalJob (ExternalJobRequest, ExternalJobReply)

  dagster_api.proto:21

  message ExternalJobRequest

  dagster_api.proto:183

  • string serialized_repository_origin = 1

  • string job_name = 2

  message ExternalJobReply

  dagster_api.proto:188

  • string serialized_job_data = 1

  • string serialized_error = 2

• rpc StreamingExternalRepository (ExternalRepositoryRequest, stream StreamingExternalRepositoryEvent)

  dagster_api.proto:22

  message StreamingExternalRepositoryEvent

  dagster_api.proto:129

  • int32 sequence_number = 1

  • string serialized_external_repository_chunk = 2

• rpc ExternalScheduleExecution (ExternalScheduleExecutionRequest, stream StreamingChunkEvent)

  dagster_api.proto:23

• rpc SyncExternalScheduleExecution (ExternalScheduleExecutionRequest, ExternalScheduleExecutionReply)

  dagster_api.proto:24

  message ExternalScheduleExecutionReply

  dagster_api.proto:193

  • string serialized_schedule_result = 1

• rpc ExternalSensorExecution (ExternalSensorExecutionRequest, stream StreamingChunkEvent)

  dagster_api.proto:25

• rpc SyncExternalSensorExecution (ExternalSensorExecutionRequest, ExternalSensorExecutionReply)

  dagster_api.proto:26

  message ExternalSensorExecutionReply

  dagster_api.proto:197

  • string serialized_sensor_result = 1

• rpc ShutdownServer (Empty, ShutdownServerReply)

  dagster_api.proto:27

  message ShutdownServerReply

  dagster_api.proto:147

  • string serialized_shutdown_server_result = 1

• rpc CancelExecution (CancelExecutionRequest, CancelExecutionReply)

  dagster_api.proto:28

  message CancelExecutionRequest

  dagster_api.proto:151

  • string serialized_cancel_execution_request = 1

  message CancelExecutionReply

  dagster_api.proto:155

  • string serialized_cancel_execution_result = 1

• rpc CanCancelExecution (CanCancelExecutionRequest, CanCancelExecutionReply)

  dagster_api.proto:29

  message CanCancelExecutionRequest

  dagster_api.proto:159

  • string serialized_can_cancel_execution_request = 1

  message CanCancelExecutionReply

  dagster_api.proto:163

  • string serialized_can_cancel_execution_result = 1

• rpc StartRun (StartRunRequest, StartRunReply)

  dagster_api.proto:30

  message StartRunRequest

  dagster_api.proto:167

  • string serialized_execute_run_args = 1

  message StartRunReply

  dagster_api.proto:171

  • string serialized_start_run_result = 1

• rpc GetCurrentImage (Empty, GetCurrentImageReply)

  dagster_api.proto:31

  message GetCurrentImageReply

  dagster_api.proto:175

  • string serialized_current_image = 1

• rpc GetCurrentRuns (Empty, GetCurrentRunsReply)

  dagster_api.proto:32

  message GetCurrentRunsReply

  dagster_api.proto:179

  • string serialized_current_runs = 1

• rpc ReloadCode (ReloadCodeRequest, ReloadCodeReply)

  dagster_api.proto:33

  message ReloadCodeRequest

  dagster_api.proto:201

  (message has no fields)

  message ReloadCodeReply

  dagster_api.proto:204

  • string serialized_error = 2

Used as request type in: DagsterApi.GetCurrentImage, DagsterApi.GetCurrentRuns, DagsterApi.GetServerId, DagsterApi.ShutdownServer

(message has no fields)

Used as request type in: DagsterApi.ExternalRepository, DagsterApi.StreamingExternalRepository

• string serialized_repository_python_origin = 1

• bool defer_snapshots = 2

Used as request type in: DagsterApi.ExternalScheduleExecution, DagsterApi.SyncExternalScheduleExecution

• string serialized_external_schedule_execution_args = 1

Used as request type in: DagsterApi.ExternalSensorExecution, DagsterApi.SyncExternalSensorExecution

• string serialized_external_sensor_execution_args = 1

Used as response type in: DagsterApi.Heartbeat, DagsterApi.Ping

• string echo = 1

• string serialized_server_utilization_metrics = 2

Used as request type in: DagsterApi.Heartbeat, DagsterApi.Ping

• string echo = 1

Used as response type in: DagsterApi.ExternalPartitionSetExecutionParams, DagsterApi.ExternalScheduleExecution, DagsterApi.ExternalSensorExecution

• int32 sequence_number = 1

• string serialized_chunk = 2