Gitiles
Code Review Sign In
gerrit-public.fairphone.software / platform / external / python / google-api-python-client / 0915761b342e18fdf56f7e1ac174ca736f679ed1 / . / docs / dyn / dataflow_v1beta3.v1b3.projects.jobs.html
blob: db0374e5087afee84fcf2c5bab5554844a552f14 [file] [log] [blame]
Craig Citroe633be12015-03-02 13:40:36 -0800[diff] [blame]1<html><body>
2<style>
3
4body, h1, h2, h3, div, span, p, pre, a {
5 margin: 0;
6 padding: 0;
7 border: 0;
8 font-weight: inherit;
9 font-style: inherit;
10 font-size: 100%;
11 font-family: inherit;
12 vertical-align: baseline;
13}
14
15body {
16 font-size: 13px;
17 padding: 1em;
18}
19
20h1 {
21 font-size: 26px;
22 margin-bottom: 1em;
23}
24
25h2 {
26 font-size: 24px;
27 margin-bottom: 1em;
28}
29
30h3 {
31 font-size: 20px;
32 margin-bottom: 1em;
33 margin-top: 1em;
34}
35
36pre, code {
37 line-height: 1.5;
38 font-family: Monaco, 'DejaVu Sans Mono', 'Bitstream Vera Sans Mono', 'Lucida Console', monospace;
39}
40
41pre {
42 margin-top: 0.5em;
43}
44
45h1, h2, h3, p {
46 font-family: Arial, sans serif;
47}
48
49h1, h2, h3 {
50 border-bottom: solid #CCC 1px;
51}
52
53.toc_element {
54 margin-top: 0.5em;
55}
56
57.firstline {
58 margin-left: 2 em;
59}
60
61.method {
62 margin-top: 1em;
63 border: solid 1px #CCC;
64 padding: 1em;
65 background: #EEE;
66}
67
68.details {
69 font-weight: bold;
70 font-size: 14px;
71}
72
73</style>
74
75<h1><a href="dataflow_v1beta3.html">Google Dataflow API</a> . <a href="dataflow_v1beta3.v1b3.html">v1b3</a> . <a href="dataflow_v1beta3.v1b3.projects.html">projects</a> . <a href="dataflow_v1beta3.v1b3.projects.jobs.html">jobs</a></h1>
76<h2>Instance Methods</h2>
77<p class="toc_element">
78 <code><a href="dataflow_v1beta3.v1b3.projects.jobs.messages.html">messages()</a></code>
79</p>
80<p class="firstline">Returns the messages Resource.</p>
81
82<p class="toc_element">
83 <code><a href="dataflow_v1beta3.v1b3.projects.jobs.workItems.html">workItems()</a></code>
84</p>
85<p class="firstline">Returns the workItems Resource.</p>
86
87<p class="toc_element">
88 <code><a href="#create">create(projectId, body, view=None)</a></code></p>
89<p class="firstline">Creates a dataflow job.</p>
90<p class="toc_element">
91 <code><a href="#get">get(projectId, jobId, view=None)</a></code></p>
92<p class="firstline">Gets the state of the specified dataflow job.</p>
93<p class="toc_element">
94 <code><a href="#getMetrics">getMetrics(projectId, jobId, startTime=None)</a></code></p>
95<p class="firstline">Request the job status.</p>
96<p class="toc_element">
97 <code><a href="#list">list(projectId, pageToken=None, pageSize=None, view=None)</a></code></p>
98<p class="firstline">List the jobs of a project</p>
99<p class="toc_element">
100 <code><a href="#list_next">list_next(previous_request, previous_response)</a></code></p>
101<p class="firstline">Retrieves the next page of results.</p>
102<p class="toc_element">
103 <code><a href="#patch">patch(projectId, jobId, body)</a></code></p>
104<p class="firstline">Updates the state of an existing dataflow job. This method supports patch semantics.</p>
105<p class="toc_element">
106 <code><a href="#update">update(projectId, jobId, body)</a></code></p>
107<p class="firstline">Updates the state of an existing dataflow job.</p>
108<h3>Method Details</h3>
109<div class="method">
110 <code class="details" id="create">create(projectId, body, view=None)</code>
111 <pre>Creates a dataflow job.
112
113Args:
114 projectId: string, A parameter (required)
115 body: object, The request body. (required)
116 The object takes the form of:
117
118{
119 "requestedState": "A String",
120 "name": "A String",
121 "projectId": "A String",
122 "createTime": "A String",
123 "environment": {
124 "version": {
125 "a_key": "",
126 },
127 "workerPools": [
128 {
129 "diskSourceImage": "A String",
130 "teardownPolicy": "A String",
131 "kind": "A String",
132 "packages": [
133 {
134 "location": "A String",
135 "name": "A String",
136 },
137 ],
138 "machineType": "A String",
139 "zone": "A String",
140 "onHostMaintenance": "A String",
141 "taskrunnerSettings": {
142 "workflowFileName": "A String",
143 "logUploadLocation": "A String",
144 "commandlinesFileName": "A String",
145 "alsologtostderr": True or False,
146 "vmId": "A String",
147 "baseTaskDir": "A String",
148 "continueOnException": True or False,
149 "baseUrl": "A String",
150 "parallelWorkerSettings": {
151 "reportingEnabled": True or False,
152 "shuffleServicePath": "A String",
153 "workerId": "A String",
154 "baseUrl": "A String",
155 "servicePath": "A String",
156 "tempStoragePrefix": "A String",
157 },
158 "oauthScopes": [
159 "A String",
160 ],
161 "taskGroup": "A String",
162 "languageHint": "A String",
163 "logToSerialconsole": True or False,
164 "streamingWorkerMainClass": "A String",
165 "logDir": "A String",
166 "dataflowApiVersion": "A String",
167 "taskUser": "A String",
168 "harnessCommand": "A String",
169 "tempStoragePrefix": "A String",
170 },
171 "diskSizeGb": 42,
172 "numWorkers": 42,
173 "defaultPackageSet": "A String",
174 "metadata": {
175 "a_key": "A String",
176 },
177 "autoscalingSettings": {
178 "maxNumWorkers": 42,
179 "algorithm": "A String",
180 },
181 "dataDisks": [
182 {
183 "mountPoint": "A String",
184 "sizeGb": 42,
185 "diskType": "A String",
186 },
187 ],
188 },
189 ],
190 "dataset": "A String",
191 "experiments": [
192 "A String",
193 ],
194 "sdkPipelineOptions": {
195 "a_key": "",
196 },
197 "userAgent": {
198 "a_key": "",
199 },
200 "clusterManagerApiService": "A String",
201 "tempStoragePrefix": "A String",
202 },
203 "steps": [
204 {
205 "kind": "A String",
206 "name": "A String",
207 "properties": {
208 "a_key": "",
209 },
210 },
211 ],
212 "currentStateTime": "A String",
213 "type": "A String",
214 "id": "A String",
215 "currentState": "A String",
216 "executionInfo": {
217 "stages": {
218 "a_key": {
219 "stepName": [
220 "A String",
221 ],
222 },
223 },
224 },
225}
226
227 view: string, A parameter
228 Allowed values
229 JOB_VIEW_ALL -
230 JOB_VIEW_SUMMARY -
231 JOB_VIEW_UNKNOWN -
232
233Returns:
234 An object of the form:
235
236 {
237 "requestedState": "A String",
238 "name": "A String",
239 "projectId": "A String",
240 "createTime": "A String",
241 "environment": {
242 "version": {
243 "a_key": "",
244 },
245 "workerPools": [
246 {
247 "diskSourceImage": "A String",
248 "teardownPolicy": "A String",
249 "kind": "A String",
250 "packages": [
251 {
252 "location": "A String",
253 "name": "A String",
254 },
255 ],
256 "machineType": "A String",
257 "zone": "A String",
258 "onHostMaintenance": "A String",
259 "taskrunnerSettings": {
260 "workflowFileName": "A String",
261 "logUploadLocation": "A String",
262 "commandlinesFileName": "A String",
263 "alsologtostderr": True or False,
264 "vmId": "A String",
265 "baseTaskDir": "A String",
266 "continueOnException": True or False,
267 "baseUrl": "A String",
268 "parallelWorkerSettings": {
269 "reportingEnabled": True or False,
270 "shuffleServicePath": "A String",
271 "workerId": "A String",
272 "baseUrl": "A String",
273 "servicePath": "A String",
274 "tempStoragePrefix": "A String",
275 },
276 "oauthScopes": [
277 "A String",
278 ],
279 "taskGroup": "A String",
280 "languageHint": "A String",
281 "logToSerialconsole": True or False,
282 "streamingWorkerMainClass": "A String",
283 "logDir": "A String",
284 "dataflowApiVersion": "A String",
285 "taskUser": "A String",
286 "harnessCommand": "A String",
287 "tempStoragePrefix": "A String",
288 },
289 "diskSizeGb": 42,
290 "numWorkers": 42,
291 "defaultPackageSet": "A String",
292 "metadata": {
293 "a_key": "A String",
294 },
295 "autoscalingSettings": {
296 "maxNumWorkers": 42,
297 "algorithm": "A String",
298 },
299 "dataDisks": [
300 {
301 "mountPoint": "A String",
302 "sizeGb": 42,
303 "diskType": "A String",
304 },
305 ],
306 },
307 ],
308 "dataset": "A String",
309 "experiments": [
310 "A String",
311 ],
312 "sdkPipelineOptions": {
313 "a_key": "",
314 },
315 "userAgent": {
316 "a_key": "",
317 },
318 "clusterManagerApiService": "A String",
319 "tempStoragePrefix": "A String",
320 },
321 "steps": [
322 {
323 "kind": "A String",
324 "name": "A String",
325 "properties": {
326 "a_key": "",
327 },
328 },
329 ],
330 "currentStateTime": "A String",
331 "type": "A String",
332 "id": "A String",
333 "currentState": "A String",
334 "executionInfo": {
335 "stages": {
336 "a_key": {
337 "stepName": [
338 "A String",
339 ],
340 },
341 },
342 },
343 }</pre>
344</div>
345
346<div class="method">
347 <code class="details" id="get">get(projectId, jobId, view=None)</code>
348 <pre>Gets the state of the specified dataflow job.
349
350Args:
351 projectId: string, A parameter (required)
352 jobId: string, A parameter (required)
353 view: string, A parameter
354 Allowed values
355 JOB_VIEW_ALL -
356 JOB_VIEW_SUMMARY -
357 JOB_VIEW_UNKNOWN -
358
359Returns:
360 An object of the form:
361
362 {
363 "requestedState": "A String",
364 "name": "A String",
365 "projectId": "A String",
366 "createTime": "A String",
367 "environment": {
368 "version": {
369 "a_key": "",
370 },
371 "workerPools": [
372 {
373 "diskSourceImage": "A String",
374 "teardownPolicy": "A String",
375 "kind": "A String",
376 "packages": [
377 {
378 "location": "A String",
379 "name": "A String",
380 },
381 ],
382 "machineType": "A String",
383 "zone": "A String",
384 "onHostMaintenance": "A String",
385 "taskrunnerSettings": {
386 "workflowFileName": "A String",
387 "logUploadLocation": "A String",
388 "commandlinesFileName": "A String",
389 "alsologtostderr": True or False,
390 "vmId": "A String",
391 "baseTaskDir": "A String",
392 "continueOnException": True or False,
393 "baseUrl": "A String",
394 "parallelWorkerSettings": {
395 "reportingEnabled": True or False,
396 "shuffleServicePath": "A String",
397 "workerId": "A String",
398 "baseUrl": "A String",
399 "servicePath": "A String",
400 "tempStoragePrefix": "A String",
401 },
402 "oauthScopes": [
403 "A String",
404 ],
405 "taskGroup": "A String",
406 "languageHint": "A String",
407 "logToSerialconsole": True or False,
408 "streamingWorkerMainClass": "A String",
409 "logDir": "A String",
410 "dataflowApiVersion": "A String",
411 "taskUser": "A String",
412 "harnessCommand": "A String",
413 "tempStoragePrefix": "A String",
414 },
415 "diskSizeGb": 42,
416 "numWorkers": 42,
417 "defaultPackageSet": "A String",
418 "metadata": {
419 "a_key": "A String",
420 },
421 "autoscalingSettings": {
422 "maxNumWorkers": 42,
423 "algorithm": "A String",
424 },
425 "dataDisks": [
426 {
427 "mountPoint": "A String",
428 "sizeGb": 42,
429 "diskType": "A String",
430 },
431 ],
432 },
433 ],
434 "dataset": "A String",
435 "experiments": [
436 "A String",
437 ],
438 "sdkPipelineOptions": {
439 "a_key": "",
440 },
441 "userAgent": {
442 "a_key": "",
443 },
444 "clusterManagerApiService": "A String",
445 "tempStoragePrefix": "A String",
446 },
447 "steps": [
448 {
449 "kind": "A String",
450 "name": "A String",
451 "properties": {
452 "a_key": "",
453 },
454 },
455 ],
456 "currentStateTime": "A String",
457 "type": "A String",
458 "id": "A String",
459 "currentState": "A String",
460 "executionInfo": {
461 "stages": {
462 "a_key": {
463 "stepName": [
464 "A String",
465 ],
466 },
467 },
468 },
469 }</pre>
470</div>
471
472<div class="method">
473 <code class="details" id="getMetrics">getMetrics(projectId, jobId, startTime=None)</code>
474 <pre>Request the job status.
475
476Args:
477 projectId: string, A parameter (required)
478 jobId: string, A parameter (required)
479 startTime: string, A parameter
480
481Returns:
482 An object of the form:
483
484 {
485 "metrics": [
486 {
487 "meanCount": "",
488 "kind": "A String",
489 "set": "",
490 "name": {
491 "origin": "A String",
492 "name": "A String",
493 "context": {
494 "a_key": "A String",
495 },
496 },
497 "meanSum": "",
498 "cumulative": True or False,
499 "updateTime": "A String",
500 "scalar": "",
501 "internal": "",
502 },
503 ],
504 "metricTime": "A String",
505 }</pre>
506</div>
507
508<div class="method">
509 <code class="details" id="list">list(projectId, pageToken=None, pageSize=None, view=None)</code>
510 <pre>List the jobs of a project
511
512Args:
513 projectId: string, A parameter (required)
514 pageToken: string, A parameter
515 pageSize: integer, A parameter
516 view: string, A parameter
517 Allowed values
518 JOB_VIEW_ALL -
519 JOB_VIEW_SUMMARY -
520 JOB_VIEW_UNKNOWN -
521
522Returns:
523 An object of the form:
524
525 {
526 "nextPageToken": "A String",
527 "jobs": [
528 {
529 "requestedState": "A String",
530 "name": "A String",
531 "projectId": "A String",
532 "createTime": "A String",
533 "environment": {
534 "version": {
535 "a_key": "",
536 },
537 "workerPools": [
538 {
539 "diskSourceImage": "A String",
540 "teardownPolicy": "A String",
541 "kind": "A String",
542 "packages": [
543 {
544 "location": "A String",
545 "name": "A String",
546 },
547 ],
548 "machineType": "A String",
549 "zone": "A String",
550 "onHostMaintenance": "A String",
551 "taskrunnerSettings": {
552 "workflowFileName": "A String",
553 "logUploadLocation": "A String",
554 "commandlinesFileName": "A String",
555 "alsologtostderr": True or False,
556 "vmId": "A String",
557 "baseTaskDir": "A String",
558 "continueOnException": True or False,
559 "baseUrl": "A String",
560 "parallelWorkerSettings": {
561 "reportingEnabled": True or False,
562 "shuffleServicePath": "A String",
563 "workerId": "A String",
564 "baseUrl": "A String",
565 "servicePath": "A String",
566 "tempStoragePrefix": "A String",
567 },
568 "oauthScopes": [
569 "A String",
570 ],
571 "taskGroup": "A String",
572 "languageHint": "A String",
573 "logToSerialconsole": True or False,
574 "streamingWorkerMainClass": "A String",
575 "logDir": "A String",
576 "dataflowApiVersion": "A String",
577 "taskUser": "A String",
578 "harnessCommand": "A String",
579 "tempStoragePrefix": "A String",
580 },
581 "diskSizeGb": 42,
582 "numWorkers": 42,
583 "defaultPackageSet": "A String",
584 "metadata": {
585 "a_key": "A String",
586 },
587 "autoscalingSettings": {
588 "maxNumWorkers": 42,
589 "algorithm": "A String",
590 },
591 "dataDisks": [
592 {
593 "mountPoint": "A String",
594 "sizeGb": 42,
595 "diskType": "A String",
596 },
597 ],
598 },
599 ],
600 "dataset": "A String",
601 "experiments": [
602 "A String",
603 ],
604 "sdkPipelineOptions": {
605 "a_key": "",
606 },
607 "userAgent": {
608 "a_key": "",
609 },
610 "clusterManagerApiService": "A String",
611 "tempStoragePrefix": "A String",
612 },
613 "steps": [
614 {
615 "kind": "A String",
616 "name": "A String",
617 "properties": {
618 "a_key": "",
619 },
620 },
621 ],
622 "currentStateTime": "A String",
623 "type": "A String",
624 "id": "A String",
625 "currentState": "A String",
626 "executionInfo": {
627 "stages": {
628 "a_key": {
629 "stepName": [
630 "A String",
631 ],
632 },
633 },
634 },
635 },
636 ],
637 }</pre>
638</div>
639
640<div class="method">
641 <code class="details" id="list_next">list_next(previous_request, previous_response)</code>
642 <pre>Retrieves the next page of results.
643
644Args:
645 previous_request: The request for the previous page. (required)
646 previous_response: The response from the request for the previous page. (required)
647
648Returns:
649 A request object that you can call 'execute()' on to request the next
650 page. Returns None if there are no more items in the collection.
651 </pre>
652</div>
653
654<div class="method">
655 <code class="details" id="patch">patch(projectId, jobId, body)</code>
656 <pre>Updates the state of an existing dataflow job. This method supports patch semantics.
657
658Args:
659 projectId: string, A parameter (required)
660 jobId: string, A parameter (required)
661 body: object, The request body. (required)
662 The object takes the form of:
663
664{
665 "requestedState": "A String",
666 "name": "A String",
667 "projectId": "A String",
668 "createTime": "A String",
669 "environment": {
670 "version": {
671 "a_key": "",
672 },
673 "workerPools": [
674 {
675 "diskSourceImage": "A String",
676 "teardownPolicy": "A String",
677 "kind": "A String",
678 "packages": [
679 {
680 "location": "A String",
681 "name": "A String",
682 },
683 ],
684 "machineType": "A String",
685 "zone": "A String",
686 "onHostMaintenance": "A String",
687 "taskrunnerSettings": {
688 "workflowFileName": "A String",
689 "logUploadLocation": "A String",
690 "commandlinesFileName": "A String",
691 "alsologtostderr": True or False,
692 "vmId": "A String",
693 "baseTaskDir": "A String",
694 "continueOnException": True or False,
695 "baseUrl": "A String",
696 "parallelWorkerSettings": {
697 "reportingEnabled": True or False,
698 "shuffleServicePath": "A String",
699 "workerId": "A String",
700 "baseUrl": "A String",
701 "servicePath": "A String",
702 "tempStoragePrefix": "A String",
703 },
704 "oauthScopes": [
705 "A String",
706 ],
707 "taskGroup": "A String",
708 "languageHint": "A String",
709 "logToSerialconsole": True or False,
710 "streamingWorkerMainClass": "A String",
711 "logDir": "A String",
712 "dataflowApiVersion": "A String",
713 "taskUser": "A String",
714 "harnessCommand": "A String",
715 "tempStoragePrefix": "A String",
716 },
717 "diskSizeGb": 42,
718 "numWorkers": 42,
719 "defaultPackageSet": "A String",
720 "metadata": {
721 "a_key": "A String",
722 },
723 "autoscalingSettings": {
724 "maxNumWorkers": 42,
725 "algorithm": "A String",
726 },
727 "dataDisks": [
728 {
729 "mountPoint": "A String",
730 "sizeGb": 42,
731 "diskType": "A String",
732 },
733 ],
734 },
735 ],
736 "dataset": "A String",
737 "experiments": [
738 "A String",
739 ],
740 "sdkPipelineOptions": {
741 "a_key": "",
742 },
743 "userAgent": {
744 "a_key": "",
745 },
746 "clusterManagerApiService": "A String",
747 "tempStoragePrefix": "A String",
748 },
749 "steps": [
750 {
751 "kind": "A String",
752 "name": "A String",
753 "properties": {
754 "a_key": "",
755 },
756 },
757 ],
758 "currentStateTime": "A String",
759 "type": "A String",
760 "id": "A String",
761 "currentState": "A String",
762 "executionInfo": {
763 "stages": {
764 "a_key": {
765 "stepName": [
766 "A String",
767 ],
768 },
769 },
770 },
771}
772
773
774Returns:
775 An object of the form:
776
777 {
778 "requestedState": "A String",
779 "name": "A String",
780 "projectId": "A String",
781 "createTime": "A String",
782 "environment": {
783 "version": {
784 "a_key": "",
785 },
786 "workerPools": [
787 {
788 "diskSourceImage": "A String",
789 "teardownPolicy": "A String",
790 "kind": "A String",
791 "packages": [
792 {
793 "location": "A String",
794 "name": "A String",
795 },
796 ],
797 "machineType": "A String",
798 "zone": "A String",
799 "onHostMaintenance": "A String",
800 "taskrunnerSettings": {
801 "workflowFileName": "A String",
802 "logUploadLocation": "A String",
803 "commandlinesFileName": "A String",
804 "alsologtostderr": True or False,
805 "vmId": "A String",
806 "baseTaskDir": "A String",
807 "continueOnException": True or False,
808 "baseUrl": "A String",
809 "parallelWorkerSettings": {
810 "reportingEnabled": True or False,
811 "shuffleServicePath": "A String",
812 "workerId": "A String",
813 "baseUrl": "A String",
814 "servicePath": "A String",
815 "tempStoragePrefix": "A String",
816 },
817 "oauthScopes": [
818 "A String",
819 ],
820 "taskGroup": "A String",
821 "languageHint": "A String",
822 "logToSerialconsole": True or False,
823 "streamingWorkerMainClass": "A String",
824 "logDir": "A String",
825 "dataflowApiVersion": "A String",
826 "taskUser": "A String",
827 "harnessCommand": "A String",
828 "tempStoragePrefix": "A String",
829 },
830 "diskSizeGb": 42,
831 "numWorkers": 42,
832 "defaultPackageSet": "A String",
833 "metadata": {
834 "a_key": "A String",
835 },
836 "autoscalingSettings": {
837 "maxNumWorkers": 42,
838 "algorithm": "A String",
839 },
840 "dataDisks": [
841 {
842 "mountPoint": "A String",
843 "sizeGb": 42,
844 "diskType": "A String",
845 },
846 ],
847 },
848 ],
849 "dataset": "A String",
850 "experiments": [
851 "A String",
852 ],
853 "sdkPipelineOptions": {
854 "a_key": "",
855 },
856 "userAgent": {
857 "a_key": "",
858 },
859 "clusterManagerApiService": "A String",
860 "tempStoragePrefix": "A String",
861 },
862 "steps": [
863 {
864 "kind": "A String",
865 "name": "A String",
866 "properties": {
867 "a_key": "",
868 },
869 },
870 ],
871 "currentStateTime": "A String",
872 "type": "A String",
873 "id": "A String",
874 "currentState": "A String",
875 "executionInfo": {
876 "stages": {
877 "a_key": {
878 "stepName": [
879 "A String",
880 ],
881 },
882 },
883 },
884 }</pre>
885</div>
886
887<div class="method">
888 <code class="details" id="update">update(projectId, jobId, body)</code>
889 <pre>Updates the state of an existing dataflow job.
890
891Args:
892 projectId: string, A parameter (required)
893 jobId: string, A parameter (required)
894 body: object, The request body. (required)
895 The object takes the form of:
896
897{
898 "requestedState": "A String",
899 "name": "A String",
900 "projectId": "A String",
901 "createTime": "A String",
902 "environment": {
903 "version": {
904 "a_key": "",
905 },
906 "workerPools": [
907 {
908 "diskSourceImage": "A String",
909 "teardownPolicy": "A String",
910 "kind": "A String",
911 "packages": [
912 {
913 "location": "A String",
914 "name": "A String",
915 },
916 ],
917 "machineType": "A String",
918 "zone": "A String",
919 "onHostMaintenance": "A String",
920 "taskrunnerSettings": {
921 "workflowFileName": "A String",
922 "logUploadLocation": "A String",
923 "commandlinesFileName": "A String",
924 "alsologtostderr": True or False,
925 "vmId": "A String",
926 "baseTaskDir": "A String",
927 "continueOnException": True or False,
928 "baseUrl": "A String",
929 "parallelWorkerSettings": {
930 "reportingEnabled": True or False,
931 "shuffleServicePath": "A String",
932 "workerId": "A String",
933 "baseUrl": "A String",
934 "servicePath": "A String",
935 "tempStoragePrefix": "A String",
936 },
937 "oauthScopes": [
938 "A String",
939 ],
940 "taskGroup": "A String",
941 "languageHint": "A String",
942 "logToSerialconsole": True or False,
943 "streamingWorkerMainClass": "A String",
944 "logDir": "A String",
945 "dataflowApiVersion": "A String",
946 "taskUser": "A String",
947 "harnessCommand": "A String",
948 "tempStoragePrefix": "A String",
949 },
950 "diskSizeGb": 42,
951 "numWorkers": 42,
952 "defaultPackageSet": "A String",
953 "metadata": {
954 "a_key": "A String",
955 },
956 "autoscalingSettings": {
957 "maxNumWorkers": 42,
958 "algorithm": "A String",
959 },
960 "dataDisks": [
961 {
962 "mountPoint": "A String",
963 "sizeGb": 42,
964 "diskType": "A String",
965 },
966 ],
967 },
968 ],
969 "dataset": "A String",
970 "experiments": [
971 "A String",
972 ],
973 "sdkPipelineOptions": {
974 "a_key": "",
975 },
976 "userAgent": {
977 "a_key": "",
978 },
979 "clusterManagerApiService": "A String",
980 "tempStoragePrefix": "A String",
981 },
982 "steps": [
983 {
984 "kind": "A String",
985 "name": "A String",
986 "properties": {
987 "a_key": "",
988 },
989 },
990 ],
991 "currentStateTime": "A String",
992 "type": "A String",
993 "id": "A String",
994 "currentState": "A String",
995 "executionInfo": {
996 "stages": {
997 "a_key": {
998 "stepName": [
999 "A String",
1000 ],
1001 },
1002 },
1003 },
1004}
1005
1006
1007Returns:
1008 An object of the form:
1009
1010 {
1011 "requestedState": "A String",
1012 "name": "A String",
1013 "projectId": "A String",
1014 "createTime": "A String",
1015 "environment": {
1016 "version": {
1017 "a_key": "",
1018 },
1019 "workerPools": [
1020 {
1021 "diskSourceImage": "A String",
1022 "teardownPolicy": "A String",
1023 "kind": "A String",
1024 "packages": [
1025 {
1026 "location": "A String",
1027 "name": "A String",
1028 },
1029 ],
1030 "machineType": "A String",
1031 "zone": "A String",
1032 "onHostMaintenance": "A String",
1033 "taskrunnerSettings": {
1034 "workflowFileName": "A String",
1035 "logUploadLocation": "A String",
1036 "commandlinesFileName": "A String",
1037 "alsologtostderr": True or False,
1038 "vmId": "A String",
1039 "baseTaskDir": "A String",
1040 "continueOnException": True or False,
1041 "baseUrl": "A String",
1042 "parallelWorkerSettings": {
1043 "reportingEnabled": True or False,
1044 "shuffleServicePath": "A String",
1045 "workerId": "A String",
1046 "baseUrl": "A String",
1047 "servicePath": "A String",
1048 "tempStoragePrefix": "A String",
1049 },
1050 "oauthScopes": [
1051 "A String",
1052 ],
1053 "taskGroup": "A String",
1054 "languageHint": "A String",
1055 "logToSerialconsole": True or False,
1056 "streamingWorkerMainClass": "A String",
1057 "logDir": "A String",
1058 "dataflowApiVersion": "A String",
1059 "taskUser": "A String",
1060 "harnessCommand": "A String",
1061 "tempStoragePrefix": "A String",
1062 },
1063 "diskSizeGb": 42,
1064 "numWorkers": 42,
1065 "defaultPackageSet": "A String",
1066 "metadata": {
1067 "a_key": "A String",
1068 },
1069 "autoscalingSettings": {
1070 "maxNumWorkers": 42,
1071 "algorithm": "A String",
1072 },
1073 "dataDisks": [
1074 {
1075 "mountPoint": "A String",
1076 "sizeGb": 42,
1077 "diskType": "A String",
1078 },
1079 ],
1080 },
1081 ],
1082 "dataset": "A String",
1083 "experiments": [
1084 "A String",
1085 ],
1086 "sdkPipelineOptions": {
1087 "a_key": "",
1088 },
1089 "userAgent": {
1090 "a_key": "",
1091 },
1092 "clusterManagerApiService": "A String",
1093 "tempStoragePrefix": "A String",
1094 },
1095 "steps": [
1096 {
1097 "kind": "A String",
1098 "name": "A String",
1099 "properties": {
1100 "a_key": "",
1101 },
1102 },
1103 ],
1104 "currentStateTime": "A String",
1105 "type": "A String",
1106 "id": "A String",
1107 "currentState": "A String",
1108 "executionInfo": {
1109 "stages": {
1110 "a_key": {
1111 "stepName": [
1112 "A String",
1113 ],
1114 },
1115 },
1116 },
1117 }</pre>
1118</div>
1119
1120</body></html>