class Google::Apis::DataflowV1b3::TaskRunnerSettings
Taskrunner configuration settings.
Attributes
Whether to also send taskrunner log info to stderr. Corresponds to the JSON property `alsologtostderr` @return [Boolean]
Whether to also send taskrunner log info to stderr. Corresponds to the JSON property `alsologtostderr` @return [Boolean]
The location on the worker for task-specific subdirectories. Corresponds to the JSON property `baseTaskDir` @return [String]
The base URL for the taskrunner to use when accessing Google
Cloud APIs. When workers access Google
Cloud APIs, they logically do so via relative URLs. If this field is specified, it supplies the base URL to use for resolving these relative URLs. The normative algorithm used is defined by RFC 1808, “Relative Uniform Resource Locators”. If not specified, the default value is “www. googleapis.com/” Corresponds to the JSON property `baseUrl` @return [String]
The file to store preprocessing commands in. Corresponds to the JSON property `commandlinesFileName` @return [String]
Whether to continue taskrunner if an exception is hit. Corresponds to the JSON property `continueOnException` @return [Boolean]
Whether to continue taskrunner if an exception is hit. Corresponds to the JSON property `continueOnException` @return [Boolean]
The API version of endpoint, e.g. “v1b3” Corresponds to the JSON property `dataflowApiVersion` @return [String]
The command to launch the worker harness. Corresponds to the JSON property `harnessCommand` @return [String]
The suggested backend language. Corresponds to the JSON property `languageHint` @return [String]
The directory on the VM to store logs. Corresponds to the JSON property `logDir` @return [String]
Whether to send taskrunner log info to Google
Compute Engine VM serial console. Corresponds to the JSON property `logToSerialconsole` @return [Boolean]
Whether to send taskrunner log info to Google
Compute Engine VM serial console. Corresponds to the JSON property `logToSerialconsole` @return [Boolean]
Indicates where to put logs. If this is not specified, the logs will not be uploaded. The supported resource type is: Google
Cloud Storage: storage. googleapis.com/`bucket`/`object` bucket.storage.googleapis.com/`object` Corresponds to the JSON property `logUploadLocation` @return [String]
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API. Corresponds to the JSON property `oauthScopes` @return [Array<String>]
Provides data to pass through to the worker harness. Corresponds to the JSON property `parallelWorkerSettings` @return [Google::Apis::DataflowV1b3::WorkerSettings]
The streaming worker main class name. Corresponds to the JSON property `streamingWorkerMainClass` @return [String]
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.
-
“wheel”.
Corresponds to the JSON property `taskGroup` @return [String]
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. “root”. Corresponds to the JSON property `taskUser` @return [String]
The prefix of the resources the taskrunner should use for temporary storage. The supported resource type is: Google
Cloud Storage: storage.googleapis.com/` bucket`/`object` bucket.storage.googleapis.com/`object` Corresponds to the JSON property `tempStoragePrefix` @return [String]
The ID string of the VM. Corresponds to the JSON property `vmId` @return [String]
The file to store the workflow in. Corresponds to the JSON property `workflowFileName` @return [String]
Public Class Methods
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5618 def initialize(**args) update!(**args) end
Public Instance Methods
Update properties of this object
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5623 def update!(**args) @alsologtostderr = args[:alsologtostderr] if args.key?(:alsologtostderr) @base_task_dir = args[:base_task_dir] if args.key?(:base_task_dir) @base_url = args[:base_url] if args.key?(:base_url) @commandlines_file_name = args[:commandlines_file_name] if args.key?(:commandlines_file_name) @continue_on_exception = args[:continue_on_exception] if args.key?(:continue_on_exception) @dataflow_api_version = args[:dataflow_api_version] if args.key?(:dataflow_api_version) @harness_command = args[:harness_command] if args.key?(:harness_command) @language_hint = args[:language_hint] if args.key?(:language_hint) @log_dir = args[:log_dir] if args.key?(:log_dir) @log_to_serialconsole = args[:log_to_serialconsole] if args.key?(:log_to_serialconsole) @log_upload_location = args[:log_upload_location] if args.key?(:log_upload_location) @oauth_scopes = args[:oauth_scopes] if args.key?(:oauth_scopes) @parallel_worker_settings = args[:parallel_worker_settings] if args.key?(:parallel_worker_settings) @streaming_worker_main_class = args[:streaming_worker_main_class] if args.key?(:streaming_worker_main_class) @task_group = args[:task_group] if args.key?(:task_group) @task_user = args[:task_user] if args.key?(:task_user) @temp_storage_prefix = args[:temp_storage_prefix] if args.key?(:temp_storage_prefix) @vm_id = args[:vm_id] if args.key?(:vm_id) @workflow_file_name = args[:workflow_file_name] if args.key?(:workflow_file_name) end