| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/surface/dataproc/jobs/ |
| H A D | delete.py | 50 job_ref = args.CONCEPTS.job.Parse()
52 projectId=job_ref.projectId,
53 region=job_ref.region,
54 jobId=job_ref.jobId)
63 def _GetJob(job_ref): argument
66 projectId=job_ref.projectId,
67 region=job_ref.region,
68 jobId=job_ref.jobId))
71 _GetJob, job_ref, message='Waiting for job deletion')
73 log.DeletedResource(job_ref)
|
| H A D | kill.py | 50 job_ref = args.CONCEPTS.job.Parse()
52 projectId=job_ref.projectId,
53 region=job_ref.region,
54 jobId=job_ref.jobId,
66 'Job cancellation initiated for [{0}].'.format(job_ref.jobId))
71 job_ref,
75 log.status.Print('Killed [{0}].'.format(job_ref))
|
| H A D | update.py | 60 job_ref = args.CONCEPTS.job.Parse()
66 projectId=job_ref.projectId,
67 region=job_ref.region,
68 jobId=job_ref.jobId))
79 projectId=job_ref.projectId,
80 region=job_ref.region,
81 jobId=job_ref.jobId,
|
| H A D | wait.py | 59 job_ref = args.CONCEPTS.job.Parse()
63 projectId=job_ref.projectId,
64 region=job_ref.region,
65 jobId=job_ref.jobId))
72 job_ref,
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/surface/dataflow/jobs/ |
| H A D | cancel.py | 46 for job_ref in job_utils.ExtractJobRefs(args):
49 job_ref.jobId,
50 project_id=job_ref.projectId,
51 region_id=job_ref.location)
52 log.status.Print('Cancelled job [{0}]'.format(job_ref.jobId))
58 job_ref.jobId, error.payload.status_message, job_ref.location))
|
| H A D | drain.py | 51 for job_ref in job_utils.ExtractJobRefs(args):
54 job_ref.jobId,
55 project_id=job_ref.projectId,
56 region_id=job_ref.location)
57 log.status.Print('Started draining job [{0}]'.format(job_ref.jobId))
63 job_ref.jobId, error.payload.status_message, job_ref.location))
|
| H A D | resume_unsupported_sdk.py | 53 job_ref = job_utils.ExtractJobRef(args)
56 job_ref.jobId,
58 project_id=job_ref.projectId,
59 region_id=job_ref.location)
64 job_ref.jobId))
70 job_ref.jobId, error.payload.status_message, job_ref.location,
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/surface/dataflow/logs/ |
| H A D | list.py | 112 job_ref = job_utils.ExtractJobRef(args)
124 projectId=job_ref.projectId,
125 jobId=job_ref.jobId,
126 location=job_ref.location,
135 job_id=job_ref.jobId,
136 project_id=job_ref.projectId,
137 region_id=job_ref.location,
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/command_lib/dataproc/jobs/ |
| H A D | submitter.py | 62 job_ref = util.ParseJob(job_id, dataproc)
75 cluster, job_ref.jobId, bucket=args.bucket)
80 projectId=job_ref.projectId,
81 jobId=job_ref.jobId),
93 projectId=job_ref.projectId,
94 region=job_ref.region,
107 job_ref,
|
| /dports/devel/stylua/StyLua-0.11.0/cargo-crates/rayon-core-1.9.1/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/multimedia/librav1e/rav1e-0.5.1/cargo-crates/rayon-core-1.9.1/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/multimedia/rav1e/rav1e-0.5.1/cargo-crates/rayon-core-1.9.1/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/misc/broot/broot-1.7.0/cargo-crates/rayon-core-1.9.1/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/devel/rust-analyzer/rust-analyzer-2021-12-20/cargo-crates/rayon-core-1.9.1/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/games/jaggedalliance2/ja2-stracciatella-0.18.0/cargo-crates/rayon-core-1.8.0/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/devel/grcov/grcov-0.8.2/cargo-crates/rayon-core-1.9.1/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/net-im/libsignal-client/libsignal-client-0.9.6/cargo-crates/rayon-core-1.9.0/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/multimedia/termplay/termplay-2.0.6/cargo-crates/rayon-core-1.7.0/src/spawn/ |
| H A D | mod.rs | 82 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
83 registry.inject_or_push(job_ref); in spawn_in()
157 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
162 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
163 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/net-im/zkgroup/zkgroup-0.7.4/cargo-crates/rayon-core-1.9.1/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/graphics/librsvg2-rust/librsvg-2.52.8/vendor/rayon-core/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/devel/racer/racer-2.1.48/cargo-crates/rustc-rayon-core-0.3.1/src/spawn/ |
| H A D | mod.rs | 82 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
83 registry.inject_or_push(job_ref); in spawn_in()
157 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
162 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
163 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rayon-core-1.7.0/src/spawn/ |
| H A D | mod.rs | 82 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
83 registry.inject_or_push(job_ref); in spawn_in()
157 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
162 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
163 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/sysutils/czkawka/czkawka-3.3.1/cargo-crates/rayon-core-1.9.1/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/rayon-core-1.9.1/src/spawn/ |
| H A D | mod.rs | 81 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
82 registry.inject_or_push(job_ref); in spawn_in()
156 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
161 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
162 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|
| /dports/textproc/sd/sd-0.7.6/cargo-crates/rayon-core-1.7.1/src/spawn/ |
| H A D | mod.rs | 82 let job_ref = spawn_job(func, registry); in spawn_in() localVariable
83 registry.inject_or_push(job_ref); in spawn_in()
157 let job_ref = spawn_job(func, registry); in spawn_fifo_in() localVariable
162 Some(worker) => worker.push_fifo(job_ref), in spawn_fifo_in()
163 None => registry.inject(&[job_ref]), in spawn_fifo_in()
|