Skip to content

Commit

Permalink
feat(dataflow): update the api
Browse files Browse the repository at this point in the history
#### dataflow:v1b3

The following keys were added:
- schemas.WorkerMessage.properties.workerThreadScalingReport.$ref (Total Keys: 1)
- schemas.WorkerMessageResponse.properties.workerThreadScalingReportResponse.$ref (Total Keys: 1)
- schemas.WorkerThreadScalingReport (Total Keys: 8)
  • Loading branch information
yoshi-automation committed Dec 13, 2022
1 parent 720850e commit 1b55a02
Show file tree
Hide file tree
Showing 3 changed files with 49 additions and 3 deletions.
6 changes: 6 additions & 0 deletions docs/dyn/dataflow_v1b3.projects.html
Expand Up @@ -196,6 +196,9 @@ <h3>Method Details</h3>
&quot;workerShutdownNotice&quot;: { # Shutdown notification from workers. This is to be sent by the shutdown script of the worker VM so that the backend knows that the VM is being shut down. # Shutdown notice by workers.
&quot;reason&quot;: &quot;A String&quot;, # The reason for the worker shutdown. Current possible values are: &quot;UNKNOWN&quot;: shutdown reason is unknown. &quot;PREEMPTION&quot;: shutdown reason is preemption. Other possible reasons may be added in the future.
},
&quot;workerThreadScalingReport&quot;: { # Contains information about the thread scaling information of a worker. # Thread scaling information reported by workers.
&quot;currentThreadCount&quot;: 42, # Current number of active threads in a worker.
},
},
],
}
Expand All @@ -218,6 +221,9 @@ <h3>Method Details</h3>
},
&quot;workerShutdownNoticeResponse&quot;: { # Service-side response to WorkerMessage issuing shutdown notice. # Service&#x27;s response to shutdown notice (currently empty).
},
&quot;workerThreadScalingReportResponse&quot;: { # Contains the thread scaling recommendation for a worker from the backend. # Service&#x27;s thread scaling recommendation for workers.
&quot;recommendedThreadCount&quot;: 42, # Recommended number of threads for a worker.
},
},
],
}</pre>
Expand Down
6 changes: 6 additions & 0 deletions docs/dyn/dataflow_v1b3.projects.locations.html
Expand Up @@ -179,6 +179,9 @@ <h3>Method Details</h3>
&quot;workerShutdownNotice&quot;: { # Shutdown notification from workers. This is to be sent by the shutdown script of the worker VM so that the backend knows that the VM is being shut down. # Shutdown notice by workers.
&quot;reason&quot;: &quot;A String&quot;, # The reason for the worker shutdown. Current possible values are: &quot;UNKNOWN&quot;: shutdown reason is unknown. &quot;PREEMPTION&quot;: shutdown reason is preemption. Other possible reasons may be added in the future.
},
&quot;workerThreadScalingReport&quot;: { # Contains information about the thread scaling information of a worker. # Thread scaling information reported by workers.
&quot;currentThreadCount&quot;: 42, # Current number of active threads in a worker.
},
},
],
}
Expand All @@ -201,6 +204,9 @@ <h3>Method Details</h3>
},
&quot;workerShutdownNoticeResponse&quot;: { # Service-side response to WorkerMessage issuing shutdown notice. # Service&#x27;s response to shutdown notice (currently empty).
},
&quot;workerThreadScalingReportResponse&quot;: { # Contains the thread scaling recommendation for a worker from the backend. # Service&#x27;s thread scaling recommendation for workers.
&quot;recommendedThreadCount&quot;: 42, # Recommended number of threads for a worker.
},
},
],
}</pre>
Expand Down
40 changes: 37 additions & 3 deletions googleapiclient/discovery_cache/documents/dataflow.v1b3.json
Expand Up @@ -2240,7 +2240,7 @@
}
}
},
"revision": "20221128",
"revision": "20221206",
"rootUrl": "https://dataflow.googleapis.com/",
"schemas": {
"ApproximateProgress": {
Expand Down Expand Up @@ -4744,7 +4744,8 @@
"GCS_WRITE_FOLDER",
"PUBSUB_TOPIC",
"PUBSUB_SUBSCRIPTION",
"BIGQUERY_TABLE"
"BIGQUERY_TABLE",
"JAVASCRIPT_UDF_FILE"
],
"enumDescriptions": [
"Default input type.",
Expand All @@ -4757,7 +4758,8 @@
"The parameter specifies a Cloud Storage folder to write to.",
"The parameter specifies a Pub/Sub Topic.",
"The parameter specifies a Pub/Sub Subscription.",
"The parameter specifies a BigQuery table."
"The parameter specifies a BigQuery table.",
"The parameter specifies a JavaScript UDF in Cloud Storage."
],
"type": "string"
},
Expand Down Expand Up @@ -7007,6 +7009,10 @@
"workerShutdownNotice": {
"$ref": "WorkerShutdownNotice",
"description": "Shutdown notice by workers."
},
"workerThreadScalingReport": {
"$ref": "WorkerThreadScalingReport",
"description": "Thread scaling information reported by workers."
}
},
"type": "object"
Expand Down Expand Up @@ -7045,6 +7051,10 @@
"workerShutdownNoticeResponse": {
"$ref": "WorkerShutdownNoticeResponse",
"description": "Service's response to shutdown notice (currently empty)."
},
"workerThreadScalingReportResponse": {
"$ref": "WorkerThreadScalingReportResponse",
"description": "Service's thread scaling recommendation for workers."
}
},
"type": "object"
Expand Down Expand Up @@ -7245,6 +7255,30 @@
"properties": {},
"type": "object"
},
"WorkerThreadScalingReport": {
"description": "Contains information about the thread scaling information of a worker.",
"id": "WorkerThreadScalingReport",
"properties": {
"currentThreadCount": {
"description": "Current number of active threads in a worker.",
"format": "int32",
"type": "integer"
}
},
"type": "object"
},
"WorkerThreadScalingReportResponse": {
"description": "Contains the thread scaling recommendation for a worker from the backend.",
"id": "WorkerThreadScalingReportResponse",
"properties": {
"recommendedThreadCount": {
"description": "Recommended number of threads for a worker.",
"format": "int32",
"type": "integer"
}
},
"type": "object"
},
"WriteInstruction": {
"description": "An instruction that writes records. Takes one input, produces no outputs.",
"id": "WriteInstruction",
Expand Down

0 comments on commit 1b55a02

Please sign in to comment.