@@ -2160,6 +2160,45 @@ def update!(**args)
21602160 end
21612161 end
21622162
2163+ # Request to get worker stacktraces from debug capture.
2164+ class GetWorkerStacktracesRequest
2165+ include Google ::Apis ::Core ::Hashable
2166+
2167+ # The worker for which to get stacktraces. The returned stacktraces will be for
2168+ # the SDK harness running on this worker.
2169+ # Corresponds to the JSON property `workerId`
2170+ # @return [String]
2171+ attr_accessor :worker_id
2172+
2173+ def initialize ( **args )
2174+ update! ( **args )
2175+ end
2176+
2177+ # Update properties of this object
2178+ def update! ( **args )
2179+ @worker_id = args [ :worker_id ] if args . key? ( :worker_id )
2180+ end
2181+ end
2182+
2183+ # Response to get worker stacktraces from debug capture.
2184+ class GetWorkerStacktracesResponse
2185+ include Google ::Apis ::Core ::Hashable
2186+
2187+ # Repeated as unified worker may have multiple SDK processes.
2188+ # Corresponds to the JSON property `sdks`
2189+ # @return [Array<Google::Apis::DataflowV1b3::Sdk>]
2190+ attr_accessor :sdks
2191+
2192+ def initialize ( **args )
2193+ update! ( **args )
2194+ end
2195+
2196+ # Update properties of this object
2197+ def update! ( **args )
2198+ @sdks = args [ :sdks ] if args . key? ( :sdks )
2199+ end
2200+ end
2201+
21632202 # Histogram of value counts for a distribution. Buckets have an inclusive lower
21642203 # bound and exclusive upper bound and use "1,2,5 bucketing": The first bucket
21652204 # range is from [0,1) and all subsequent bucket boundaries are powers of ten
@@ -4856,6 +4895,31 @@ def update!(**args)
48564895 end
48574896 end
48584897
4898+ # A structured representation of an SDK.
4899+ class Sdk
4900+ include Google ::Apis ::Core ::Hashable
4901+
4902+ # The SDK harness id.
4903+ # Corresponds to the JSON property `sdkId`
4904+ # @return [String]
4905+ attr_accessor :sdk_id
4906+
4907+ # The stacktraces for the processes running on the SDK harness.
4908+ # Corresponds to the JSON property `stacks`
4909+ # @return [Array<Google::Apis::DataflowV1b3::Stack>]
4910+ attr_accessor :stacks
4911+
4912+ def initialize ( **args )
4913+ update! ( **args )
4914+ end
4915+
4916+ # Update properties of this object
4917+ def update! ( **args )
4918+ @sdk_id = args [ :sdk_id ] if args . key? ( :sdk_id )
4919+ @stacks = args [ :stacks ] if args . key? ( :stacks )
4920+ end
4921+ end
4922+
48594923 # A bug found in the Dataflow SDK.
48604924 class SdkBug
48614925 include Google ::Apis ::Core ::Hashable
@@ -5809,6 +5873,51 @@ def update!(**args)
58095873 end
58105874 end
58115875
5876+ # A structuredstacktrace for a process running on the worker.
5877+ class Stack
5878+ include Google ::Apis ::Core ::Hashable
5879+
5880+ # The raw stack trace.
5881+ # Corresponds to the JSON property `stackContent`
5882+ # @return [String]
5883+ attr_accessor :stack_content
5884+
5885+ # With java thread dumps we may get collapsed stacks e.g., N threads in stack "".
5886+ # Instead of having to copy over the same stack trace N times, this int field
5887+ # captures this.
5888+ # Corresponds to the JSON property `threadCount`
5889+ # @return [Fixnum]
5890+ attr_accessor :thread_count
5891+
5892+ # Thread name. For example, "CommitThread-0,10,main"
5893+ # Corresponds to the JSON property `threadName`
5894+ # @return [String]
5895+ attr_accessor :thread_name
5896+
5897+ # The state of the thread. For example, "WAITING".
5898+ # Corresponds to the JSON property `threadState`
5899+ # @return [String]
5900+ attr_accessor :thread_state
5901+
5902+ # Timestamp at which the stack was captured.
5903+ # Corresponds to the JSON property `timestamp`
5904+ # @return [String]
5905+ attr_accessor :timestamp
5906+
5907+ def initialize ( **args )
5908+ update! ( **args )
5909+ end
5910+
5911+ # Update properties of this object
5912+ def update! ( **args )
5913+ @stack_content = args [ :stack_content ] if args . key? ( :stack_content )
5914+ @thread_count = args [ :thread_count ] if args . key? ( :thread_count )
5915+ @thread_name = args [ :thread_name ] if args . key? ( :thread_name )
5916+ @thread_state = args [ :thread_state ] if args . key? ( :thread_state )
5917+ @timestamp = args [ :timestamp ] if args . key? ( :timestamp )
5918+ end
5919+ end
5920+
58125921 # Information about the workers and work items within a stage.
58135922 class StageExecutionDetails
58145923 include Google ::Apis ::Core ::Hashable
0 commit comments