Flyte Propeller Configuration

Section: admin

endpoint ( config.URL)

For admin types, specify where the uri of the service is located.

Default Value:

""

insecure (bool)

Use insecure connection.

Default Value:

"false"

insecureSkipVerify (bool)

InsecureSkipVerify controls whether a client verifies the server's certificate chain and host name. Caution : shouldn't be use for production usecases'

Default Value:

"false"

caCertFilePath (string)

Use specified certificate file to verify the admin server peer.

Default Value:

""

maxBackoffDelay ( config.Duration)

Max delay for grpc backoff

Default Value:

8s

perRetryTimeout ( config.Duration)

gRPC per retry timeout

Default Value:

15s

maxRetries (int)

Max number of gRPC retries

Default Value:

"4"

maxMessageSizeBytes (int)

The max size in bytes for incoming gRPC messages

Default Value:

"0"

authType (uint8)

Type of OAuth2 flow used for communicating with admin.ClientSecret,Pkce,ExternalCommand are valid values

Default Value:

ClientSecret

tokenRefreshWindow ( config.Duration)

Max duration between token refresh attempt and token expiry.

Default Value:

0s

useAuth (bool)

Deprecated: Auth will be enabled/disabled based on admin's dynamically discovered information.

Default Value:

"false"

clientId (string)

Client ID

Default Value:

flytepropeller

clientSecretLocation (string)

File containing the client secret

Default Value:

/etc/secrets/client_secret

clientSecretEnvVar (string)

Environment variable containing the client secret

Default Value:

""

scopes ([]string)

List of scopes to request

Default Value:

[]

useAudienceFromAdmin (bool)

Use Audience configured from admins public endpoint config.

Default Value:

"false"

audience (string)

Audience to use when initiating OAuth2 authorization requests.

Default Value:

""

authorizationServerUrl (string)

This is the URL to your IdP's authorization server. It'll default to Endpoint

Default Value:

""

tokenUrl (string)

OPTIONAL: Your IdP's token endpoint. It'll be discovered from flyte admin's OAuth Metadata endpoint if not provided.

Default Value:

""

authorizationHeader (string)

Custom metadata header to pass JWT

Default Value:

""

pkceConfig ( pkce.Config)

Config for Pkce authentication flow.

Default Value:

refreshTime: 5m0s
timeout: 2m0s

deviceFlowConfig ( deviceflow.Config)

Config for Device authentication flow.

Default Value:

pollInterval: 5s
refreshTime: 5m0s
timeout: 10m0s

command ([]string)

Command for external authentication token generation

Default Value:

[]

proxyCommand ([]string)

Command for external proxy-authorization token generation

Default Value:

[]

defaultServiceConfig (string)

Default Value:

""

httpProxyURL ( config.URL)

OPTIONAL: HTTP Proxy to be used for OAuth requests.

Default Value:

""

config.Duration

Duration (int64)

Default Value:

8s

config.URL

URL ( url.URL)

Default Value:

ForceQuery: false
Fragment: ""
Host: ""
OmitHost: false
Opaque: ""
Path: ""
RawFragment: ""
RawPath: ""
RawQuery: ""
Scheme: ""
User: null

url.URL

Scheme (string)

Default Value:

""
Opaque (string)

Default Value:

""
User (url.Userinfo)

Default Value:

null
Host (string)

Default Value:

""
Path (string)

Default Value:

""
RawPath (string)

Default Value:

""
OmitHost (bool)

Default Value:

"false"
ForceQuery (bool)

Default Value:

"false"
RawQuery (string)

Default Value:

""
Fragment (string)

Default Value:

""
RawFragment (string)

Default Value:

""

deviceflow.Config

refreshTime ( config.Duration)

grace period from the token expiry after which it would refresh the token.

Default Value:

5m0s
timeout ( config.Duration)

amount of time the device flow should complete or else it will be cancelled.

Default Value:

10m0s
pollInterval ( config.Duration)

amount of time the device flow would poll the token endpoint if auth server doesn't return a polling interval. Okta and google IDP do return an interval'

Default Value:

5s

pkce.Config

timeout ( config.Duration)

Amount of time the browser session would be active for authentication from client app.

Default Value:

2m0s
refreshTime ( config.Duration)

grace period from the token expiry after which it would refresh the token.

Default Value:

5m0s

Section: catalog-cache

type (string)

Catalog Implementation to use

Default Value:

noop

endpoint (string)

Endpoint for catalog service

Default Value:

""

insecure (bool)

Use insecure grpc connection

Default Value:

"false"

max-cache-age ( config.Duration)

Cache entries past this age will incur cache miss. 0 means cache never expires

Default Value:

0s

use-admin-auth (bool)

Use the same gRPC credentials option as the flyteadmin client

Default Value:

"false"

max-retries (int)

The max number of retries for event recording.

Default Value:

"5"

base-scalar (int)

The base/scalar backoff duration in milliseconds for event recording retries.

Default Value:

"100"

backoff-jitter (string)

A string representation of a floating point number between 0 and 1 specifying the jitter factor for event recording retries.

Default Value:

"0.1"

default-service-config (string)

Set the default service config for the catalog gRPC client

Default Value:

""

Section: event

type (string)

Sets the type of EventSink to configure [log/admin/file].

Default Value:

admin

file-path (string)

For file types, specify where the file should be located.

Default Value:

""

rate (int64)

Max rate at which events can be recorded per second.

Default Value:

"500"

capacity (int)

The max bucket size for event recording tokens.

Default Value:

"1000"

max-retries (int)

The max number of retries for event recording.

Default Value:

"5"

base-scalar (int)

The base/scalar backoff duration in milliseconds for event recording retries.

Default Value:

"100"

backoff-jitter (string)

A string representation of a floating point number between 0 and 1 specifying the jitter factor for event recording retries.

Default Value:

"0.1"

Section: logger

show-source (bool)

Includes source code location in logs.

Default Value:

"false"

mute (bool)

Mutes all logs regardless of severity. Intended for benchmarks/tests only.

Default Value:

"false"

level (int)

Sets the minimum logging level.

Default Value:

"3"

formatter ( logger.FormatterConfig)

Sets logging format.

Default Value:

type: json

logger.FormatterConfig

type (string)

Sets logging format type.

Default Value:

json

Section: otel

type (string)

Sets the type of exporter to configure [noop/file/jaeger/otlpgrpc/otlphttp].

Default Value:

noop

file ( otelutils.FileConfig)

Configuration for exporting telemetry traces to a file

Default Value:

filename: /tmp/trace.txt

jaeger ( otelutils.JaegerConfig)

Configuration for exporting telemetry traces to a jaeger

Default Value:

endpoint: http://localhost:14268/api/traces

otlpgrpc ( otelutils.OtlpGrpcConfig)

Configuration for exporting telemetry traces to an OTLP gRPC collector

Default Value:

endpoint: http://localhost:4317

otlphttp ( otelutils.OtlpHttpConfig)

Configuration for exporting telemetry traces to an OTLP HTTP collector

Default Value:

endpoint: http://localhost:4318/v1/traces

sampler ( otelutils.SamplerConfig)

Configuration for the sampler to use for the tracer

Default Value:

parentSampler: always
traceIdRatio: 0.01

otelutils.FileConfig

filename (string)

Filename to store exported telemetry traces

Default Value:

/tmp/trace.txt

otelutils.JaegerConfig

endpoint (string)

Endpoint for the jaeger telemetry trace ingestor

Default Value:

http://localhost:14268/api/traces

otelutils.OtlpGrpcConfig

endpoint (string)

Endpoint for the OTLP telemetry trace collector

Default Value:

http://localhost:4317

otelutils.OtlpHttpConfig

endpoint (string)

Endpoint for the OTLP telemetry trace collector

Default Value:

http://localhost:4318/v1/traces

otelutils.SamplerConfig

parentSampler (string)

Sets the parent sampler to use for the tracer

Default Value:

always
traceIdRatio (float64)

Default Value:

"0.01"

Section: plugins

connector-service ( connector.Config)

Default Value:

connectorForTaskTypes: null
connectors: null
defaultConnector:
  defaultServiceConfig: '{"loadBalancingConfig": [{"round_robin":{}}]}'
  defaultTimeout: 3s
  endpoint: ""
  insecure: true
  timeouts: null
pollInterval: 10s
resourceConstraints:
  NamespaceScopeResourceConstraint:
    Value: 50
  ProjectScopeResourceConstraint:
    Value: 100
supportedTaskTypes:
- task_type_1
- task_type_2
webApi:
  caching:
    maxSystemFailures: 5
    resyncInterval: 30s
    size: 500000
    workers: 10
  readRateLimiter:
    burst: 100
    qps: 10
  resourceMeta: null
  resourceQuotas:
    default: 1000
  writeRateLimiter:
    burst: 100
    qps: 10

athena ( athena.Config)

Default Value:

defaultCatalog: AwsDataCatalog
defaultWorkGroup: primary
resourceConstraints:
  NamespaceScopeResourceConstraint:
    Value: 50
  ProjectScopeResourceConstraint:
    Value: 100
webApi:
  caching:
    maxSystemFailures: 5
    resyncInterval: 30s
    size: 500000
    workers: 10
  readRateLimiter:
    burst: 100
    qps: 10
  resourceMeta: null
  resourceQuotas:
    default: 1000
  writeRateLimiter:
    burst: 100
    qps: 10

aws ( aws.Config)

Default Value:

accountId: ""
logLevel: 0
region: us-east-2
retries: 3

bigquery ( bigquery.Config)

Default Value:

googleTokenSource:
  gke-task-workload-identity:
    remoteClusterConfig:
      auth:
        caCertPath: ""
        tokenPath: ""
      enabled: false
      endpoint: ""
      name: ""
  type: default
resourceConstraints:
  NamespaceScopeResourceConstraint:
    Value: 50
  ProjectScopeResourceConstraint:
    Value: 100
webApi:
  caching:
    maxSystemFailures: 5
    resyncInterval: 30s
    size: 500000
    workers: 10
  readRateLimiter:
    burst: 100
    qps: 10
  resourceMeta: null
  resourceQuotas:
    default: 1000
  writeRateLimiter:
    burst: 100
    qps: 10

catalogcache ( catalog.Config)

Default Value:

reader:
  maxItems: 10000
  maxRetries: 3
  workers: 10
writer:
  maxItems: 10000
  maxRetries: 3
  workers: 10

connector-service ( connector.Config)

Default Value:

connectorForTaskTypes: {}
connectors: {}
defaultConnector:
  defaultServiceConfig: '{"loadBalancingConfig": [{"round_robin":{}}]}'
  defaultTimeout: 10s
  endpoint: ""
  insecure: true
  timeouts: null
pollInterval: 10s
resourceConstraints:
  NamespaceScopeResourceConstraint:
    Value: 50
  ProjectScopeResourceConstraint:
    Value: 100
supportedTaskTypes:
- task_type_3
- task_type_4
webApi:
  caching:
    maxSystemFailures: 5
    resyncInterval: 30s
    size: 500000
    workers: 10
  readRateLimiter:
    burst: 100
    qps: 10
  resourceMeta: null
  resourceQuotas:
    default: 1000
  writeRateLimiter:
    burst: 100
    qps: 10

dask ( dask.Config)

Default Value:

logs:
  cloudwatch-enabled: false
  cloudwatch-log-group: ""
  cloudwatch-region: ""
  cloudwatch-template-uri: ""
  dynamic-log-links: null
  gcp-project: ""
  kubernetes-enabled: true
  kubernetes-template-uri: http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName
    }}/pod?namespace={{ .namespace }}
  kubernetes-url: ""
  stackdriver-enabled: false
  stackdriver-logresourcename: ""
  stackdriver-template-uri: ""
  templates: null

databricks ( databricks.Config)

Default Value:

databricksInstance: ""
databricksTokenKey: FLYTE_DATABRICKS_API_TOKEN
defaultWarehouse: COMPUTE_CLUSTER
entrypointFile: ""
resourceConstraints:
  NamespaceScopeResourceConstraint:
    Value: 50
  ProjectScopeResourceConstraint:
    Value: 100
webApi:
  caching:
    maxSystemFailures: 5
    resyncInterval: 30s
    size: 500000
    workers: 10
  readRateLimiter:
    burst: 100
    qps: 10
  resourceMeta: null
  resourceQuotas:
    default: 1000
  writeRateLimiter:
    burst: 100
    qps: 10

echo ( testing.Config)

Default Value:

sleep-duration: 0s

k8s ( config.K8sPluginConfig)

Default Value:

add-tolerations-for-extended-resources: []
co-pilot:
  cpu: 500m
  default-input-path: /var/flyte/inputs
  default-output-path: /var/flyte/outputs
  image: cr.flyte.org/flyteorg/flytecopilot:v0.0.15
  input-vol-name: flyte-inputs
  memory: 128Mi
  name: flyte-copilot-
  output-vol-name: flyte-outputs
  start-timeout: 1m40s
  storage: ""
create-container-config-error-grace-period: 0s
create-container-error-grace-period: 3m0s
default-annotations:
  cluster-autoscaler.kubernetes.io/safe-to-evict: "false"
default-cpus: "1"
default-env-from-configmaps: null
default-env-from-secrets: null
default-env-vars: null
default-env-vars-from-env: null
default-labels: null
default-memory: 1Gi
default-node-selector: null
default-pod-dns-config: null
default-pod-security-context: null
default-pod-template-name: ""
default-pod-template-resync: 30s
default-security-context: null
default-tolerations: null
delete-resource-on-finalize: false
enable-distributed-error-aggregation: false
enable-host-networking-pod: null
gpu-device-node-label: k8s.amazonaws.com/accelerator
gpu-partition-size-node-label: k8s.amazonaws.com/gpu-partition-size
gpu-resource-name: nvidia.com/gpu
gpu-unpartitioned-node-selector-requirement: null
gpu-unpartitioned-toleration: null
image-pull-backoff-grace-period: 3m0s
image-pull-policy: ""
inject-finalizer: false
interruptible-node-selector: null
interruptible-node-selector-requirement: null
interruptible-tolerations: null
non-interruptible-node-selector-requirement: null
pod-pending-timeout: 0s
resource-tolerations: null
scheduler-name: ""
send-object-events: false
update-backoff-retries: 5
update-base-backoff-duration: 10

k8s-array ( k8s.Config)

Default Value:

ErrorAssembler:
  maxItems: 100000
  maxRetries: 5
  workers: 10
OutputAssembler:
  maxItems: 100000
  maxRetries: 5
  workers: 10
logs:
  config:
    cloudwatch-enabled: false
    cloudwatch-log-group: ""
    cloudwatch-region: ""
    cloudwatch-template-uri: ""
    dynamic-log-links: null
    gcp-project: ""
    kubernetes-enabled: true
    kubernetes-template-uri: http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName
      }}/pod?namespace={{ .namespace }}
    kubernetes-url: ""
    stackdriver-enabled: false
    stackdriver-logresourcename: ""
    stackdriver-template-uri: ""
    templates: null
maxArrayJobSize: 5000
maxErrorLength: 1000
namespaceTemplate: ""
node-selector: null
remoteClusterConfig:
  auth:
    certPath: ""
    tokenPath: ""
    type: ""
  enabled: false
  endpoint: ""
  name: ""
resourceConfig:
  limit: 0
  primaryLabel: ""
scheduler: ""
tolerations: null

kf-operator ( common.Config)

Default Value:

timeout: 1m0s

logs ( logs.LogConfig)

Default Value:

cloudwatch-enabled: false
cloudwatch-log-group: ""
cloudwatch-region: ""
cloudwatch-template-uri: ""
dynamic-log-links: null
gcp-project: ""
kubernetes-enabled: true
kubernetes-template-uri: http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName
  }}/pod?namespace={{ .namespace }}
kubernetes-url: ""
stackdriver-enabled: false
stackdriver-logresourcename: ""
stackdriver-template-uri: ""
templates: null

qubole ( config.Config)

Default Value:

analyzeLinkPath: /v2/analyze
clusterConfigs:
- labels:
  - default
  limit: 100
  namespaceScopeQuotaProportionCap: 0.7
  primaryLabel: default
  projectScopeQuotaProportionCap: 0.7
commandApiPath: /api/v1.2/commands/
defaultClusterLabel: default
destinationClusterConfigs: []
endpoint: https://wellness.qubole.com
lruCacheSize: 2000
quboleTokenKey: FLYTE_QUBOLE_CLIENT_TOKEN
workers: 15

ray ( ray.Config)

Default Value:

dashboardHost: 0.0.0.0
dashboardURLTemplate: null
defaults:
  headNode:
    ipAddress: $MY_POD_IP
    startParameters:
      disable-usage-stats: "true"
  workerNode:
    ipAddress: $MY_POD_IP
    startParameters:
      disable-usage-stats: "true"
enableUsageStats: false
includeDashboard: true
logs:
  cloudwatch-enabled: false
  cloudwatch-log-group: ""
  cloudwatch-region: ""
  cloudwatch-template-uri: ""
  dynamic-log-links: null
  gcp-project: ""
  kubernetes-enabled: false
  kubernetes-template-uri: ""
  kubernetes-url: ""
  stackdriver-enabled: false
  stackdriver-logresourcename: ""
  stackdriver-template-uri: ""
  templates: null
logsSidecar: null
remoteClusterConfig:
  auth:
    caCertPath: ""
    tokenPath: ""
  enabled: false
  endpoint: ""
  name: ""
serviceAccount: ""
serviceType: NodePort
shutdownAfterJobFinishes: true
ttlSecondsAfterFinished: 3600

snowflake ( snowflake.Config)

Default Value:

defaultWarehouse: COMPUTE_WH
resourceConstraints:
  NamespaceScopeResourceConstraint:
    Value: 50
  ProjectScopeResourceConstraint:
    Value: 100
snowflakeTokenKey: FLYTE_SNOWFLAKE_CLIENT_TOKEN
webApi:
  caching:
    maxSystemFailures: 5
    resyncInterval: 30s
    size: 500000
    workers: 10
  readRateLimiter:
    burst: 100
    qps: 10
  resourceMeta: null
  resourceQuotas:
    default: 1000
  writeRateLimiter:
    burst: 100
    qps: 10

spark ( spark.Config)

Default Value:

features: null
logs:
  all-user:
    cloudwatch-enabled: false
    cloudwatch-log-group: ""
    cloudwatch-region: ""
    cloudwatch-template-uri: ""
    dynamic-log-links: null
    gcp-project: ""
    kubernetes-enabled: false
    kubernetes-template-uri: ""
    kubernetes-url: ""
    stackdriver-enabled: false
    stackdriver-logresourcename: ""
    stackdriver-template-uri: ""
    templates: null
  mixed:
    cloudwatch-enabled: false
    cloudwatch-log-group: ""
    cloudwatch-region: ""
    cloudwatch-template-uri: ""
    dynamic-log-links: null
    gcp-project: ""
    kubernetes-enabled: true
    kubernetes-template-uri: http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName
      }}/pod?namespace={{ .namespace }}
    kubernetes-url: ""
    stackdriver-enabled: false
    stackdriver-logresourcename: ""
    stackdriver-template-uri: ""
    templates: null
  system:
    cloudwatch-enabled: false
    cloudwatch-log-group: ""
    cloudwatch-region: ""
    cloudwatch-template-uri: ""
    dynamic-log-links: null
    gcp-project: ""
    kubernetes-enabled: false
    kubernetes-template-uri: ""
    kubernetes-url: ""
    stackdriver-enabled: false
    stackdriver-logresourcename: ""
    stackdriver-template-uri: ""
    templates: null
  user:
    cloudwatch-enabled: false
    cloudwatch-log-group: ""
    cloudwatch-region: ""
    cloudwatch-template-uri: ""
    dynamic-log-links: null
    gcp-project: ""
    kubernetes-enabled: false
    kubernetes-template-uri: ""
    kubernetes-url: ""
    stackdriver-enabled: false
    stackdriver-logresourcename: ""
    stackdriver-template-uri: ""
    templates: null
spark-config-default: null
spark-history-server-url: ""

connector.Config

webApi ( webapi.PluginConfig)

Defines config for the base WebAPI plugin.

Default Value:

caching:
  maxSystemFailures: 5
  resyncInterval: 30s
  size: 500000
  workers: 10
readRateLimiter:
  burst: 100
  qps: 10
resourceMeta: null
resourceQuotas:
  default: 1000
writeRateLimiter:
  burst: 100
  qps: 10
resourceConstraints ( core.ResourceConstraintsSpec)

Default Value:

NamespaceScopeResourceConstraint:
  Value: 50
ProjectScopeResourceConstraint:
  Value: 100
defaultConnector ( connector.Deployment)

The default connector.

Default Value:

defaultServiceConfig: '{"loadBalancingConfig": [{"round_robin":{}}]}'
defaultTimeout: 3s
endpoint: ""
insecure: true
timeouts: null
connectors (map[string]*connector.Deployment)

The connectors.

Default Value:

null
connectorForTaskTypes (map[string]string)

Default Value:

null
supportedTaskTypes ([]string)

Default Value:

- task_type_1
- task_type_2
pollInterval ( config.Duration)

The interval at which the plugin should poll the connector for metadata updates.

Default Value:

10s

connector.Deployment

endpoint (string)

Default Value:

""
insecure (bool)

Default Value:

"true"
defaultServiceConfig (string)

Default Value:

'{"loadBalancingConfig": [{"round_robin":{}}]}'
timeouts (map[string]config.Duration)

Default Value:

null
defaultTimeout ( config.Duration)

Default Value:

3s

core.ResourceConstraintsSpec

ProjectScopeResourceConstraint ( core.ResourceConstraint)

Default Value:

Value: 100
NamespaceScopeResourceConstraint ( core.ResourceConstraint)

Default Value:

Value: 50

core.ResourceConstraint

Value (int64)

Default Value:

"100"

webapi.PluginConfig

resourceQuotas (webapi.ResourceQuotas)

Default Value:

default: 1000
readRateLimiter ( webapi.RateLimiterConfig)

Defines rate limiter properties for read actions (e.g. retrieve status).

Default Value:

burst: 100
qps: 10
writeRateLimiter ( webapi.RateLimiterConfig)

Defines rate limiter properties for write actions.

Default Value:

burst: 100
qps: 10
caching ( webapi.CachingConfig)

Defines caching characteristics.

Default Value:

maxSystemFailures: 5
resyncInterval: 30s
size: 500000
workers: 10
resourceMeta (interface)

Default Value:

<nil>

webapi.CachingConfig

size (int)

Defines the maximum number of items to cache.

Default Value:

"500000"
resyncInterval ( config.Duration)

Defines the sync interval.

Default Value:

30s
workers (int)

Defines the number of workers to start up to process items.

Default Value:

"10"
maxSystemFailures (int)

Defines the number of failures to fetch a task before failing the task.

Default Value:

"5"

webapi.RateLimiterConfig

qps (int)

Defines the max rate of calls per second.

Default Value:

"10"
burst (int)

Defines the maximum burst size.

Default Value:

"100"

athena.Config

webApi ( webapi.PluginConfig)

Defines config for the base WebAPI plugin.

Default Value:

caching:
  maxSystemFailures: 5
  resyncInterval: 30s
  size: 500000
  workers: 10
readRateLimiter:
  burst: 100
  qps: 10
resourceMeta: null
resourceQuotas:
  default: 1000
writeRateLimiter:
  burst: 100
  qps: 10
resourceConstraints ( core.ResourceConstraintsSpec)

Default Value:

NamespaceScopeResourceConstraint:
  Value: 50
ProjectScopeResourceConstraint:
  Value: 100
defaultWorkGroup (string)

Defines the default workgroup to use when running on Athena unless overwritten by the task.

Default Value:

primary
defaultCatalog (string)

Defines the default catalog to use when running on Athena unless overwritten by the task.

Default Value:

AwsDataCatalog

aws.Config

region (string)

AWS Region to connect to.

Default Value:

us-east-2
accountId (string)

AWS Account Identifier.

Default Value:

""
retries (int)

Number of retries.

Default Value:

"3"
logLevel (uint64)

Default Value:

"0"

bigquery.Config

webApi ( webapi.PluginConfig)

Defines config for the base WebAPI plugin.

Default Value:

caching:
  maxSystemFailures: 5
  resyncInterval: 30s
  size: 500000
  workers: 10
readRateLimiter:
  burst: 100
  qps: 10
resourceMeta: null
resourceQuotas:
  default: 1000
writeRateLimiter:
  burst: 100
  qps: 10
resourceConstraints ( core.ResourceConstraintsSpec)

Default Value:

NamespaceScopeResourceConstraint:
  Value: 50
ProjectScopeResourceConstraint:
  Value: 100
googleTokenSource ( google.TokenSourceFactoryConfig)

Defines Google token source

Default Value:

gke-task-workload-identity:
  remoteClusterConfig:
    auth:
      caCertPath: ""
      tokenPath: ""
    enabled: false
    endpoint: ""
    name: ""
type: default
bigQueryEndpoint (string)

Default Value:

""

google.TokenSourceFactoryConfig

type (string)

Defines type of TokenSourceFactory, possible values are 'default' and 'gke-task-workload-identity'

Default Value:

default
gke-task-workload-identity ( google.GkeTaskWorkloadIdentityTokenSourceFactoryConfig)

Extra configuration for GKE task workload identity token source factory

Default Value:

remoteClusterConfig:
  auth:
    caCertPath: ""
    tokenPath: ""
  enabled: false
  endpoint: ""
  name: ""

google.GkeTaskWorkloadIdentityTokenSourceFactoryConfig

remoteClusterConfig ( k8s.ClusterConfig)

Configuration of remote GKE cluster

Default Value:

auth:
  caCertPath: ""
  tokenPath: ""
enabled: false
endpoint: ""
name: ""

k8s.ClusterConfig

name (string)

Friendly name of the remote cluster

Default Value:

""
endpoint (string)

Remote K8s cluster endpoint

Default Value:

""
auth ( k8s.Auth)

Default Value:

caCertPath: ""
tokenPath: ""
enabled (bool)

Boolean flag to enable or disable

Default Value:

"false"

k8s.Auth

tokenPath (string)

Token path

Default Value:

""
caCertPath (string)

Certificate path

Default Value:

""

catalog.Config

reader ( workqueue.Config)

Catalog reader workqueue config. Make sure the index cache must be big enough to accommodate the biggest array task allowed to run on the system.

Default Value:

maxItems: 10000
maxRetries: 3
workers: 10
writer ( workqueue.Config)

Catalog writer workqueue config. Make sure the index cache must be big enough to accommodate the biggest array task allowed to run on the system.

Default Value:

maxItems: 10000
maxRetries: 3
workers: 10

workqueue.Config

workers (int)

Number of concurrent workers to start processing the queue.

Default Value:

"10"
maxRetries (int)

Maximum number of retries per item.

Default Value:

"3"
maxItems (int)

Maximum number of entries to keep in the index.

Default Value:

"10000"

common.Config

timeout ( config.Duration)

Default Value:

1m0s

config.Config

endpoint ( config.URL)

Endpoint for qubole to use

Default Value:

https://wellness.qubole.com
commandApiPath ( config.URL)

API Path where commands can be launched on Qubole. Should be a valid url.

Default Value:

/api/v1.2/commands/
analyzeLinkPath ( config.URL)

URL path where queries can be visualized on qubole website. Should be a valid url.

Default Value:

/v2/analyze
quboleTokenKey (string)

Name of the key where to find Qubole token in the secret manager.

Default Value:

FLYTE_QUBOLE_CLIENT_TOKEN
lruCacheSize (int)

Size of the AutoRefreshCache

Default Value:

"2000"
workers (int)

Number of parallel workers to refresh the cache

Default Value:

"15"
defaultClusterLabel (string)

The default cluster label. This will be used if label is not specified on the hive job.

Default Value:

default
clusterConfigs ([]config.ClusterConfig)

Default Value:

- labels:
  - default
  limit: 100
  namespaceScopeQuotaProportionCap: 0.7
  primaryLabel: default
  projectScopeQuotaProportionCap: 0.7
destinationClusterConfigs ([]config.DestinationClusterConfig)

Default Value:

[]

config.K8sPluginConfig

inject-finalizer (bool)

Instructs the plugin to inject a finalizer on startTask and remove it on task termination.

Default Value:

"false"
default-annotations (map[string]string)

Default Value:

cluster-autoscaler.kubernetes.io/safe-to-evict: "false"
default-labels (map[string]string)

Default Value:

null
default-env-vars (map[string]string)

Default Value:

null
default-env-vars-from-env (map[string]string)

Default Value:

null
default-env-from-configmaps ([]string)

Default Value:

null
default-env-from-secrets ([]string)

Default Value:

null
default-cpus ( resource.Quantity)

Defines a default value for cpu for containers if not specified.

Default Value:

"1"
default-memory ( resource.Quantity)

Defines a default value for memory for containers if not specified.

Default Value:

1Gi
default-tolerations ([]v1.Toleration)

Default Value:

null
default-node-selector (map[string]string)

Default Value:

null
default-affinity (v1.Affinity)

Default Value:

null
scheduler-name (string)

Defines scheduler name.

Default Value:

""
interruptible-tolerations ([]v1.Toleration)

Default Value:

null
interruptible-node-selector (map[string]string)

Default Value:

null
interruptible-node-selector-requirement (v1.NodeSelectorRequirement)

Default Value:

null
non-interruptible-node-selector-requirement (v1.NodeSelectorRequirement)

Default Value:

null
resource-tolerations (map[v1.ResourceName][]v1.Toleration)

Default Value:

null
co-pilot ( config.FlyteCoPilotConfig)

Co-Pilot Configuration

Default Value:

cpu: 500m
default-input-path: /var/flyte/inputs
default-output-path: /var/flyte/outputs
image: cr.flyte.org/flyteorg/flytecopilot:v0.0.15
input-vol-name: flyte-inputs
memory: 128Mi
name: flyte-copilot-
output-vol-name: flyte-outputs
start-timeout: 1m40s
storage: ""
delete-resource-on-finalize (bool)

Instructs the system to delete the resource upon successful execution of a k8s pod rather than have the k8s garbage collector clean it up. This ensures that no resources are kept around (potentially consuming cluster resources). This, however, will cause k8s log links to expire as soon as the resource is finalized.

Default Value:

"false"
create-container-error-grace-period ( config.Duration)

Default Value:

3m0s
create-container-config-error-grace-period ( config.Duration)

Default Value:

0s
image-pull-backoff-grace-period ( config.Duration)

Default Value:

3m0s
image-pull-policy (string)

Default Value:

""
pod-pending-timeout ( config.Duration)

Default Value:

0s
gpu-device-node-label (string)

Default Value:

k8s.amazonaws.com/accelerator
gpu-partition-size-node-label (string)

Default Value:

k8s.amazonaws.com/gpu-partition-size
gpu-unpartitioned-node-selector-requirement (v1.NodeSelectorRequirement)

Default Value:

null
gpu-unpartitioned-toleration (v1.Toleration)

Default Value:

null
gpu-resource-name (string)

Default Value:

nvidia.com/gpu
default-pod-security-context (v1.PodSecurityContext)

Default Value:

null
default-security-context (v1.SecurityContext)

Default Value:

null
enable-host-networking-pod (bool)

Default Value:

<invalid reflect.Value>
default-pod-dns-config (v1.PodDNSConfig)

Default Value:

null
default-pod-template-name (string)

Name of the PodTemplate to use as the base for all k8s pods created by FlytePropeller.

Default Value:

""
default-pod-template-resync ( config.Duration)

Frequency of resyncing default pod templates

Default Value:

30s
send-object-events (bool)

If true, will send k8s object events in TaskExecutionEvent updates.

Default Value:

"false"
update-base-backoff-duration (int)

Initial delay in exponential backoff when updating a resource in milliseconds.

Default Value:

"10"
update-backoff-retries (int)

Number of retries for exponential backoff when updating a resource.

Default Value:

"5"
add-tolerations-for-extended-resources ([]string)

Name of the extended resources for which tolerations should be added.

Default Value:

[]
enable-distributed-error-aggregation (bool)

If true, will aggregate errors of different worker pods for distributed tasks.

Default Value:

"false"

config.FlyteCoPilotConfig

name (string)

Flyte co-pilot sidecar container name prefix. (additional bits will be added after this)

Default Value:

flyte-copilot-
image (string)

Flyte co-pilot Docker Image FQN

Default Value:

cr.flyte.org/flyteorg/flytecopilot:v0.0.15
default-input-path (string)

Default path where the volume should be mounted

Default Value:

/var/flyte/inputs
default-output-path (string)

Default path where the volume should be mounted

Default Value:

/var/flyte/outputs
input-vol-name (string)

Name of the data volume that is created for storing inputs

Default Value:

flyte-inputs
output-vol-name (string)

Name of the data volume that is created for storing outputs

Default Value:

flyte-outputs
start-timeout ( config.Duration)

Default Value:

1m40s
cpu (string)

Used to set cpu for co-pilot containers

Default Value:

500m
memory (string)

Used to set memory for co-pilot containers

Default Value:

128Mi
storage (string)

Default storage limit for individual inputs / outputs

Default Value:

""

resource.Quantity

i ( resource.int64Amount)

Default Value:

{}
d ( resource.infDecAmount)

Default Value:

<nil>
s (string)

Default Value:

"1"
Format (string)

Default Value:

DecimalSI

resource.infDecAmount

Dec (inf.Dec)

Default Value:

null

resource.int64Amount

value (int64)

Default Value:

"1"
scale (int32)

Default Value:

"0"

connector.Config

webApi ( webapi.PluginConfig)

Defines config for the base WebAPI plugin.

Default Value:

caching:
  maxSystemFailures: 5
  resyncInterval: 30s
  size: 500000
  workers: 10
readRateLimiter:
  burst: 100
  qps: 10
resourceMeta: null
resourceQuotas:
  default: 1000
writeRateLimiter:
  burst: 100
  qps: 10
resourceConstraints ( core.ResourceConstraintsSpec)

Default Value:

NamespaceScopeResourceConstraint:
  Value: 50
ProjectScopeResourceConstraint:
  Value: 100
defaultConnector ( connector.Deployment)

The default connector.

Default Value:

defaultServiceConfig: '{"loadBalancingConfig": [{"round_robin":{}}]}'
defaultTimeout: 10s
endpoint: ""
insecure: true
timeouts: null
connectors (map[string]*connector.Deployment)

The connectors.

Default Value:

{}
connectorForTaskTypes (map[string]string)

Default Value:

{}
supportedTaskTypes ([]string)

Default Value:

- task_type_3
- task_type_4
pollInterval ( config.Duration)

The interval at which the plugin should poll the connector for metadata updates.

Default Value:

10s

connector.Deployment

endpoint (string)

Default Value:

""
insecure (bool)

Default Value:

"true"
defaultServiceConfig (string)

Default Value:

'{"loadBalancingConfig": [{"round_robin":{}}]}'
timeouts (map[string]config.Duration)

Default Value:

null
defaultTimeout ( config.Duration)

Default Value:

10s

dask.Config

logs ( logs.LogConfig (logs))

Default Value:

cloudwatch-enabled: false
cloudwatch-log-group: ""
cloudwatch-region: ""
cloudwatch-template-uri: ""
dynamic-log-links: null
gcp-project: ""
kubernetes-enabled: true
kubernetes-template-uri: http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName
  }}/pod?namespace={{ .namespace }}
kubernetes-url: ""
stackdriver-enabled: false
stackdriver-logresourcename: ""
stackdriver-template-uri: ""
templates: null

logs.LogConfig (logs)

cloudwatch-enabled (bool)

Enable Cloudwatch Logging

Default Value:

"false"
cloudwatch-region (string)

AWS region in which Cloudwatch logs are stored.

Default Value:

""
cloudwatch-log-group (string)

Log group to which streams are associated.

Default Value:

""
cloudwatch-template-uri (string)

Template Uri to use when building cloudwatch log links

Default Value:

""
kubernetes-enabled (bool)

Enable Kubernetes Logging

Default Value:

"true"
kubernetes-url (string)

Console URL for Kubernetes logs

Default Value:

""
kubernetes-template-uri (string)

Template Uri to use when building kubernetes log links

Default Value:

http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName }}/pod?namespace={{ .namespace
  }}
stackdriver-enabled (bool)

Enable Log-links to stackdriver

Default Value:

"false"
gcp-project (string)

Name of the project in GCP

Default Value:

""
stackdriver-logresourcename (string)

Name of the logresource in stackdriver

Default Value:

""
stackdriver-template-uri (string)

Template Uri to use when building stackdriver log links

Default Value:

""

Default Value:

null
templates ([]tasklog.TemplateLogPlugin)

Default Value:

null

databricks.Config

webApi ( webapi.PluginConfig)

Defines config for the base WebAPI plugin.

Default Value:

caching:
  maxSystemFailures: 5
  resyncInterval: 30s
  size: 500000
  workers: 10
readRateLimiter:
  burst: 100
  qps: 10
resourceMeta: null
resourceQuotas:
  default: 1000
writeRateLimiter:
  burst: 100
  qps: 10
resourceConstraints ( core.ResourceConstraintsSpec)

Default Value:

NamespaceScopeResourceConstraint:
  Value: 50
ProjectScopeResourceConstraint:
  Value: 100
defaultWarehouse (string)

Defines the default warehouse to use when running on Databricks unless overwritten by the task.

Default Value:

COMPUTE_CLUSTER
databricksTokenKey (string)

Name of the key where to find Databricks token in the secret manager.

Default Value:

FLYTE_DATABRICKS_API_TOKEN
databricksInstance (string)

Databricks workspace instance name.

Default Value:

""
entrypointFile (string)

A URL of the entrypoint file. DBFS and cloud storage (s3://, gcs://, adls://, etc) locations are supported.

Default Value:

""
databricksEndpoint (string)

Default Value:

""

k8s.Config

scheduler (string)

Decides the scheduler to use when launching array-pods.

Default Value:

""
maxErrorLength (int)

Determines the maximum length of the error string returned for the array.

Default Value:

"1000"
maxArrayJobSize (int64)

Maximum size of array job.

Default Value:

"5000"
resourceConfig ( k8s.ResourceConfig)

Default Value:

limit: 0
primaryLabel: ""
remoteClusterConfig ( k8s.ClusterConfig (remoteClusterConfig))

Default Value:

auth:
  certPath: ""
  tokenPath: ""
  type: ""
enabled: false
endpoint: ""
name: ""
node-selector (map[string]string)

Default Value:

null
tolerations ([]v1.Toleration)

Default Value:

null
namespaceTemplate (string)

Default Value:

""
OutputAssembler ( workqueue.Config)

Default Value:

maxItems: 100000
maxRetries: 5
workers: 10
ErrorAssembler ( workqueue.Config)

Default Value:

maxItems: 100000
maxRetries: 5
workers: 10
logs ( k8s.LogConfig)

Config for log links for k8s array jobs.

Default Value:

config:
  cloudwatch-enabled: false
  cloudwatch-log-group: ""
  cloudwatch-region: ""
  cloudwatch-template-uri: ""
  dynamic-log-links: null
  gcp-project: ""
  kubernetes-enabled: true
  kubernetes-template-uri: http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName
    }}/pod?namespace={{ .namespace }}
  kubernetes-url: ""
  stackdriver-enabled: false
  stackdriver-logresourcename: ""
  stackdriver-template-uri: ""
  templates: null

k8s.ClusterConfig (remoteClusterConfig)

name (string)

Friendly name of the remote cluster

Default Value:

""
endpoint (string)

Remote K8s cluster endpoint

Default Value:

""
auth ( k8s.Auth (auth))

Default Value:

certPath: ""
tokenPath: ""
type: ""
enabled (bool)

Boolean flag to enable or disable

Default Value:

"false"

k8s.Auth (auth)

type (string)

Authentication type

Default Value:

""
tokenPath (string)

Token path

Default Value:

""
certPath (string)

Certificate path

Default Value:

""

k8s.LogConfig

config ( logs.LogConfig)

Defines the log config for k8s logs.

Default Value:

cloudwatch-enabled: false
cloudwatch-log-group: ""
cloudwatch-region: ""
cloudwatch-template-uri: ""
dynamic-log-links: null
gcp-project: ""
kubernetes-enabled: true
kubernetes-template-uri: http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName
  }}/pod?namespace={{ .namespace }}
kubernetes-url: ""
stackdriver-enabled: false
stackdriver-logresourcename: ""
stackdriver-template-uri: ""
templates: null

k8s.ResourceConfig

primaryLabel (string)

PrimaryLabel of a given service cluster

Default Value:

""
limit (int)

Resource quota (in the number of outstanding requests) for the cluster

Default Value:

"0"

logs.LogConfig

cloudwatch-enabled (bool)

Enable Cloudwatch Logging

Default Value:

"false"
cloudwatch-region (string)

AWS region in which Cloudwatch logs are stored.

Default Value:

""
cloudwatch-log-group (string)

Log group to which streams are associated.

Default Value:

""
cloudwatch-template-uri (string)

Template Uri to use when building cloudwatch log links

Default Value:

""
kubernetes-enabled (bool)

Enable Kubernetes Logging

Default Value:

"true"
kubernetes-url (string)

Console URL for Kubernetes logs

Default Value:

""
kubernetes-template-uri (string)

Template Uri to use when building kubernetes log links

Default Value:

http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName }}/pod?namespace={{ .namespace
  }}
stackdriver-enabled (bool)

Enable Log-links to stackdriver

Default Value:

"false"
gcp-project (string)

Name of the project in GCP

Default Value:

""
stackdriver-logresourcename (string)

Name of the logresource in stackdriver

Default Value:

""
stackdriver-template-uri (string)

Template Uri to use when building stackdriver log links

Default Value:

""

Default Value:

null
templates ([]tasklog.TemplateLogPlugin)

Default Value:

null

ray.Config

shutdownAfterJobFinishes (bool)

Default Value:

"true"
ttlSecondsAfterFinished (int32)

Default Value:

"3600"
serviceType (string)

Default Value:

NodePort
includeDashboard (bool)

Default Value:

"true"
dashboardHost (string)

Default Value:

0.0.0.0
nodeIPAddress (string)

Default Value:

""
remoteClusterConfig ( k8s.ClusterConfig)

Configuration of remote K8s cluster for ray jobs

Default Value:

auth:
  caCertPath: ""
  tokenPath: ""
enabled: false
endpoint: ""
name: ""
logs ( logs.LogConfig)

Default Value:

cloudwatch-enabled: false
cloudwatch-log-group: ""
cloudwatch-region: ""
cloudwatch-template-uri: ""
dynamic-log-links: null
gcp-project: ""
kubernetes-enabled: false
kubernetes-template-uri: ""
kubernetes-url: ""
stackdriver-enabled: false
stackdriver-logresourcename: ""
stackdriver-template-uri: ""
templates: null
logsSidecar (v1.Container)

Default Value:

null
dashboardURLTemplate (tasklog.TemplateLogPlugin)

Default Value:

null
defaults ( ray.DefaultConfig)

Default Value:

headNode:
  ipAddress: $MY_POD_IP
  startParameters:
    disable-usage-stats: "true"
workerNode:
  ipAddress: $MY_POD_IP
  startParameters:
    disable-usage-stats: "true"
enableUsageStats (bool)

Enable usage stats for ray jobs. These stats are submitted to usage-stats.ray.io per https://docs.ray.io/en/latest/cluster/usage-stats.html

Default Value:

"false"
serviceAccount (string)

The k8s service account to run as

Default Value:

""

ray.DefaultConfig

headNode ( ray.NodeConfig)

Default Value:

ipAddress: $MY_POD_IP
startParameters:
  disable-usage-stats: "true"
workerNode ( ray.NodeConfig)

Default Value:

ipAddress: $MY_POD_IP
startParameters:
  disable-usage-stats: "true"

ray.NodeConfig

startParameters (map[string]string)

Default Value:

disable-usage-stats: "true"
ipAddress (string)

Default Value:

$MY_POD_IP

snowflake.Config

webApi ( webapi.PluginConfig)

Defines config for the base WebAPI plugin.

Default Value:

caching:
  maxSystemFailures: 5
  resyncInterval: 30s
  size: 500000
  workers: 10
readRateLimiter:
  burst: 100
  qps: 10
resourceMeta: null
resourceQuotas:
  default: 1000
writeRateLimiter:
  burst: 100
  qps: 10
resourceConstraints ( core.ResourceConstraintsSpec)

Default Value:

NamespaceScopeResourceConstraint:
  Value: 50
ProjectScopeResourceConstraint:
  Value: 100
defaultWarehouse (string)

Defines the default warehouse to use when running on Snowflake unless overwritten by the task.

Default Value:

COMPUTE_WH
snowflakeTokenKey (string)

Name of the key where to find Snowflake token in the secret manager.

Default Value:

FLYTE_SNOWFLAKE_CLIENT_TOKEN
snowflakeEndpoint (string)

Default Value:

""

spark.Config

spark-config-default (map[string]string)

Default Value:

null
spark-history-server-url (string)

URL for SparkHistory Server that each job will publish the execution history to.

Default Value:

""
features ([]spark.Feature)

Default Value:

null
logs ( spark.LogConfig)

Config for log links for spark applications.

Default Value:

all-user:
  cloudwatch-enabled: false
  cloudwatch-log-group: ""
  cloudwatch-region: ""
  cloudwatch-template-uri: ""
  dynamic-log-links: null
  gcp-project: ""
  kubernetes-enabled: false
  kubernetes-template-uri: ""
  kubernetes-url: ""
  stackdriver-enabled: false
  stackdriver-logresourcename: ""
  stackdriver-template-uri: ""
  templates: null
mixed:
  cloudwatch-enabled: false
  cloudwatch-log-group: ""
  cloudwatch-region: ""
  cloudwatch-template-uri: ""
  dynamic-log-links: null
  gcp-project: ""
  kubernetes-enabled: true
  kubernetes-template-uri: http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName
    }}/pod?namespace={{ .namespace }}
  kubernetes-url: ""
  stackdriver-enabled: false
  stackdriver-logresourcename: ""
  stackdriver-template-uri: ""
  templates: null
system:
  cloudwatch-enabled: false
  cloudwatch-log-group: ""
  cloudwatch-region: ""
  cloudwatch-template-uri: ""
  dynamic-log-links: null
  gcp-project: ""
  kubernetes-enabled: false
  kubernetes-template-uri: ""
  kubernetes-url: ""
  stackdriver-enabled: false
  stackdriver-logresourcename: ""
  stackdriver-template-uri: ""
  templates: null
user:
  cloudwatch-enabled: false
  cloudwatch-log-group: ""
  cloudwatch-region: ""
  cloudwatch-template-uri: ""
  dynamic-log-links: null
  gcp-project: ""
  kubernetes-enabled: false
  kubernetes-template-uri: ""
  kubernetes-url: ""
  stackdriver-enabled: false
  stackdriver-logresourcename: ""
  stackdriver-template-uri: ""
  templates: null

spark.LogConfig

mixed ( logs.LogConfig)

Defines the log config that's not split into user/system.

Default Value:

cloudwatch-enabled: false
cloudwatch-log-group: ""
cloudwatch-region: ""
cloudwatch-template-uri: ""
dynamic-log-links: null
gcp-project: ""
kubernetes-enabled: true
kubernetes-template-uri: http://localhost:30082/#!/log/{{ .namespace }}/{{ .podName
  }}/pod?namespace={{ .namespace }}
kubernetes-url: ""
stackdriver-enabled: false
stackdriver-logresourcename: ""
stackdriver-template-uri: ""
templates: null
user ( logs.LogConfig)

Defines the log config for user logs.

Default Value:

cloudwatch-enabled: false
cloudwatch-log-group: ""
cloudwatch-region: ""
cloudwatch-template-uri: ""
dynamic-log-links: null
gcp-project: ""
kubernetes-enabled: false
kubernetes-template-uri: ""
kubernetes-url: ""
stackdriver-enabled: false
stackdriver-logresourcename: ""
stackdriver-template-uri: ""
templates: null
system ( logs.LogConfig)

Defines the log config for system logs.

Default Value:

cloudwatch-enabled: false
cloudwatch-log-group: ""
cloudwatch-region: ""
cloudwatch-template-uri: ""
dynamic-log-links: null
gcp-project: ""
kubernetes-enabled: false
kubernetes-template-uri: ""
kubernetes-url: ""
stackdriver-enabled: false
stackdriver-logresourcename: ""
stackdriver-template-uri: ""
templates: null
all-user ( logs.LogConfig)

All user logs across driver and executors.

Default Value:

cloudwatch-enabled: false
cloudwatch-log-group: ""
cloudwatch-region: ""
cloudwatch-template-uri: ""
dynamic-log-links: null
gcp-project: ""
kubernetes-enabled: false
kubernetes-template-uri: ""
kubernetes-url: ""
stackdriver-enabled: false
stackdriver-logresourcename: ""
stackdriver-template-uri: ""
templates: null

testing.Config

sleep-duration ( config.Duration)

Indicates the amount of time before transitioning to success

Default Value:

0s

Section: propeller

kube-config (string)

Path to kubernetes client config file.

Default Value:

""

master (string)

Default Value:

""

workers (int)

Number of threads to process workflows

Default Value:

"20"

workflow-reeval-duration ( config.Duration)

Frequency of re-evaluating workflows

Default Value:

10s

downstream-eval-duration ( config.Duration)

Frequency of re-evaluating downstream tasks

Default Value:

30s

limit-namespace (string)

Namespaces to watch for this propeller

Default Value:

all

prof-port ( config.Port)

Profiler port

Default Value:

10254

metadata-prefix (string)

MetadataPrefix should be used if all the metadata for Flyte executions should be stored under a specific prefix in CloudStorage. If not specified, the data will be stored in the base container directly.

Default Value:

metadata/propeller

rawoutput-prefix (string)

a fully qualified storage path of the form s3://flyte/abc/..., where all data sandboxes should be stored.

Default Value:

""

queue ( config.CompositeQueueConfig)

Workflow workqueue configuration, affects the way the work is consumed from the queue.

Default Value:

batch-size: -1
batching-interval: 1s
queue:
  base-delay: 0s
  capacity: 10000
  max-delay: 1m0s
  rate: 1000
  type: maxof
sub-queue:
  base-delay: 0s
  capacity: 10000
  max-delay: 0s
  rate: 1000
  type: bucket
type: batch

metrics-prefix (string)

An optional prefix for all published metrics.

Default Value:

flyte

metrics-keys ([]string)

Metrics labels applied to prometheus metrics emitted by the service.

Default Value:

- project
- domain
- wf
- task

enable-admin-launcher (bool)

Enable remote Workflow launcher to Admin

Default Value:

"true"

max-workflow-retries (int)

Maximum number of retries per workflow

Default Value:

"10"

max-ttl-hours (int)

Maximum number of hours a completed workflow should be retained. Number between 1-23 hours

Default Value:

"23"

gc-interval ( config.Duration)

Run periodic GC every 30 minutes

Default Value:

30m0s

leader-election ( config.LeaderElectionConfig)

Config for leader election.

Default Value:

enabled: false
lease-duration: 15s
lock-config-map:
  Name: ""
  Namespace: ""
renew-deadline: 10s
retry-period: 2s

publish-k8s-events (bool)

Enable events publishing to K8s events API.

Default Value:

"false"

max-output-size-bytes (int64)

Deprecated! Use storage.limits.maxDownloadMBs instead

Default Value:

"-1"

enable-grpc-latency-metrics (bool)

Enable grpc latency metrics. Note Histograms metrics can be expensive on Prometheus servers.

Default Value:

"false"

kube-client-config ( config.KubeClientConfig)

Configuration to control the Kubernetes client

Default Value:

burst: 25
qps: 100
timeout: 30s

node-config ( config.NodeConfig)

config for a workflow node

Default Value:

default-deadlines:
  node-active-deadline: 0s
  node-execution-deadline: 0s
  workflow-active-deadline: 0s
default-max-attempts: 1
enable-cr-debug-metadata: false
ignore-retry-cause: false
interruptible-failure-threshold: -1
max-node-retries-system-failures: 3

max-streak-length (int)

Maximum number of consecutive rounds that one propeller worker can use for one workflow - >1 => turbo-mode is enabled.

Default Value:

"8"

event-config ( config.EventConfig)

Configures execution event behavior.

Default Value:

fallback-to-output-reference: false
raw-output-policy: reference

include-shard-key-label ([]string)

Include the specified shard key label in the k8s FlyteWorkflow CRD label selector

Default Value:

[]

exclude-shard-key-label ([]string)

Exclude the specified shard key label from the k8s FlyteWorkflow CRD label selector

Default Value:

[]

include-project-label ([]string)

Include the specified project label in the k8s FlyteWorkflow CRD label selector

Default Value:

[]

exclude-project-label ([]string)

Exclude the specified project label from the k8s FlyteWorkflow CRD label selector

Default Value:

[]

include-domain-label ([]string)

Include the specified domain label in the k8s FlyteWorkflow CRD label selector

Default Value:

[]

exclude-domain-label ([]string)

Exclude the specified domain label from the k8s FlyteWorkflow CRD label selector

Default Value:

[]

cluster-id (string)

Unique cluster id running this flytepropeller instance with which to annotate execution events

Default Value:

propeller

create-flyteworkflow-crd (bool)

Enable creation of the FlyteWorkflow CRD on startup

Default Value:

"false"

node-execution-worker-count (int)

Number of workers to evaluate node executions, currently only used for array nodes

Default Value:

"8"

array-node-config ( config.ArrayNodeConfig)

Configuration for array nodes

Default Value:

default-parallelism-behavior: unlimited
event-version: 0
use-map-plugin-logs: false

literal-offloading-config ( config.LiteralOffloadingConfig)

config used for literal offloading.

Default Value:

Enabled: false
max-size-in-mb-for-offloading: 1000
min-size-in-mb-for-offloading: 10
supported-sdk-versions:
  FLYTE_SDK: 1.13.14

admin-launcher ( launchplan.AdminConfig)

Default Value:

burst: 10
cache-resync-duration: 30s
cacheSize: 10000
tps: 100
workers: 10

resourcemanager ( config.Config (resourcemanager))

Default Value:

redis:
  hostKey: ""
  hostPath: ""
  hostPaths: []
  maxRetries: 0
  primaryName: ""
resourceMaxQuota: 1000
type: noop

workflowstore ( workflowstore.Config)

Default Value:

policy: ResourceVersionCache

config.ArrayNodeConfig

event-version (int)

ArrayNode eventing version. 0 => legacy (drop-in replacement for maptask), 1 => new

Default Value:

"0"
default-parallelism-behavior (string)

Default parallelism behavior for array nodes

Default Value:

unlimited
use-map-plugin-logs (bool)

Override subNode log links with those configured for the map plugin logs

Default Value:

"false"

config.CompositeQueueConfig

type (string)

Type of composite queue to use for the WorkQueue

Default Value:

batch
queue ( config.WorkqueueConfig)

Workflow workqueue configuration, affects the way the work is consumed from the queue.

Default Value:

base-delay: 0s
capacity: 10000
max-delay: 1m0s
rate: 1000
type: maxof
sub-queue ( config.WorkqueueConfig)

SubQueue configuration, affects the way the nodes cause the top-level Work to be re-evaluated.

Default Value:

base-delay: 0s
capacity: 10000
max-delay: 0s
rate: 1000
type: bucket
batching-interval ( config.Duration)

Duration for which downstream updates are buffered

Default Value:

1s
batch-size (int)

Default Value:

"-1"

config.WorkqueueConfig

type (string)

Type of RateLimiter to use for the WorkQueue

Default Value:

maxof
base-delay ( config.Duration)

base backoff delay for failure

Default Value:

0s
max-delay ( config.Duration)

Max backoff delay for failure

Default Value:

1m0s
rate (int64)

Bucket Refill rate per second

Default Value:

"1000"
capacity (int)

Bucket capacity as number of items

Default Value:

"10000"

config.Config (resourcemanager)

type (string)

Which resource manager to use, redis or noop. Default is noop.

Default Value:

noop
resourceMaxQuota (int)

Global limit for concurrent Qubole queries

Default Value:

"1000"
redis ( config.RedisConfig)

Config for Redis resourcemanager.

Default Value:

hostKey: ""
hostPath: ""
hostPaths: []
maxRetries: 0
primaryName: ""

config.RedisConfig

hostPaths ([]string)

Redis hosts locations.

Default Value:

[]
primaryName (string)

Redis primary name, fill in only if you are connecting to a redis sentinel cluster.

Default Value:

""
hostPath (string)

Redis host location

Default Value:

""
hostKey (string)

Key for local Redis access

Default Value:

""
maxRetries (int)

See Redis client options for more info

Default Value:

"0"

config.EventConfig

raw-output-policy (string)

How output data should be passed along in execution events.

Default Value:

reference
fallback-to-output-reference (bool)

Whether output data should be sent by reference when it is too large to be sent inline in execution events.

Default Value:

"false"
ErrorOnAlreadyExists (bool)

Default Value:

"false"

config.KubeClientConfig

qps (float32)

Default Value:

"100"
burst (int)

Max burst rate for throttle. 0 defaults to 10

Default Value:

"25"
timeout ( config.Duration)

Max duration allowed for every request to KubeAPI before giving up. 0 implies no timeout.

Default Value:

30s

config.LeaderElectionConfig

enabled (bool)

Enables/Disables leader election.

Default Value:

"false"
lock-config-map ( types.NamespacedName)

ConfigMap namespace/name to use for resource lock.

Default Value:

Name: ""
Namespace: ""
lease-duration ( config.Duration)

Duration that non-leader candidates will wait to force acquire leadership. This is measured against time of last observed ack.

Default Value:

15s
renew-deadline ( config.Duration)

Duration that the acting master will retry refreshing leadership before giving up.

Default Value:

10s
retry-period ( config.Duration)

Duration the LeaderElector clients should wait between tries of actions.

Default Value:

2s

types.NamespacedName

Namespace (string)

Default Value:

""
Name (string)

Default Value:

""

config.LiteralOffloadingConfig

Enabled (bool)

Default Value:

"false"
supported-sdk-versions (map[string]string)

Maps flytekit and union SDK names to minimum supported version that can handle reading offloaded literals.

Default Value:

FLYTE_SDK: 1.13.14
min-size-in-mb-for-offloading (int64)

Size of a literal at which to trigger offloading

Default Value:

"10"
max-size-in-mb-for-offloading (int64)

Size of a literal at which to fail fast

Default Value:

"1000"

config.NodeConfig

default-deadlines ( config.DefaultDeadlines)

Default value for timeouts

Default Value:

node-active-deadline: 0s
node-execution-deadline: 0s
workflow-active-deadline: 0s
max-node-retries-system-failures (int64)

Maximum number of retries per node for node failure due to infra issues

Default Value:

"3"
interruptible-failure-threshold (int32)

number of failures for a node to be still considered interruptible. Negative numbers are treated as complementary (ex. -1 means last attempt is non-interruptible).'

Default Value:

"-1"
default-max-attempts (int32)

Default maximum number of attempts for a node

Default Value:

"1"
ignore-retry-cause (bool)

Ignore retry cause and count all attempts toward a node's max attempts

Default Value:

"false"
enable-cr-debug-metadata (bool)

Collapse node on any terminal state, not just successful terminations. This is useful to reduce the size of workflow state in etcd.

Default Value:

"false"

config.DefaultDeadlines

node-execution-deadline ( config.Duration)

Default value of node execution timeout that includes the time spent to run the node/workflow

Default Value:

0s
node-active-deadline ( config.Duration)

Default value of node timeout that includes the time spent queued.

Default Value:

0s
workflow-active-deadline ( config.Duration)

Default value of workflow timeout that includes the time spent queued.

Default Value:

0s

config.Port

port (int)

Default Value:

"10254"

launchplan.AdminConfig

tps (int64)

The maximum number of transactions per second to flyte admin from this client.

Default Value:

"100"
burst (int)

Maximum burst for throttle

Default Value:

"10"
cacheSize (int)

Maximum cache in terms of number of items stored.

Default Value:

"10000"
workers (int)

Number of parallel workers to work on the queue.

Default Value:

"10"
cache-resync-duration ( config.Duration)

Frequency of re-syncing launchplans within the auto refresh cache.

Default Value:

30s

workflowstore.Config

policy (string)

Workflow Store Policy to initialize

Default Value:

ResourceVersionCache

Section: secrets

secrets-prefix (string)

Prefix where to look for secrets file

Default Value:

/etc/secrets

env-prefix (string)

Prefix for environment variables

Default Value:

FLYTE_SECRET_

Section: storage

type (string)

Sets the type of storage to configure [s3/minio/local/mem/stow].

Default Value:

s3

connection ( storage.ConnectionConfig)

Default Value:

access-key: ""
auth-type: iam
disable-ssl: false
endpoint: ""
region: us-east-1
secret-key: ""

stow ( storage.StowConfig)

Storage config for stow backend.

Default Value:

{}

container (string)

Initial container (in s3 a bucket) to create -if it doesn't exist-.'

Default Value:

""

enable-multicontainer (bool)

If this is true, then the container argument is overlooked and redundant. This config will automatically open new connections to new containers/buckets as they are encountered

Default Value:

"false"

cache ( storage.CachingConfig)

Default Value:

max_size_mbs: 0
target_gc_percent: 0

limits ( storage.LimitsConfig)

Sets limits for stores.

Default Value:

maxDownloadMBs: 2

defaultHttpClient ( storage.HTTPClientConfig)

Sets the default http client config.

Default Value:

headers: null
timeout: 0s

signedUrl ( storage.SignedURLConfig)

Sets config for SignedURL.

Default Value:

{}

storage.CachingConfig

max_size_mbs (int)

Maximum size of the cache where the Blob store data is cached in-memory. If not specified or set to 0, cache is not used

Default Value:

"0"
target_gc_percent (int)

Sets the garbage collection target percentage.

Default Value:

"0"

storage.ConnectionConfig

endpoint ( config.URL)

URL for storage client to connect to.

Default Value:

""
auth-type (string)

Auth Type to use [iam,accesskey].

Default Value:

iam
access-key (string)

Access key to use. Only required when authtype is set to accesskey.

Default Value:

""
secret-key (string)

Secret to use when accesskey is set.

Default Value:

""
region (string)

Region to connect to.

Default Value:

us-east-1
disable-ssl (bool)

Disables SSL connection. Should only be used for development.

Default Value:

"false"

storage.HTTPClientConfig

headers (map[string][]string)

Default Value:

null
timeout ( config.Duration)

Sets time out on the http client.

Default Value:

0s

storage.LimitsConfig

maxDownloadMBs (int64)

Maximum allowed download size (in MBs) per call.

Default Value:

"2"

storage.SignedURLConfig

stowConfigOverride (map[string]string)

Default Value:

null

storage.StowConfig

kind (string)

Kind of Stow backend to use. Refer to github/flyteorg/stow

Default Value:

""
config (map[string]string)

Configuration for stow backend. Refer to github/flyteorg/stow

Default Value:

{}

Section: tasks

task-plugins ( config.TaskPluginConfig)

Task plugin configuration

Default Value:

default-for-task-types: {}
enabled-plugins: []

max-plugin-phase-versions (int32)

Maximum number of plugin phase versions allowed for one phase.

Default Value:

"100000"

backoff ( config.BackOffConfig)

Config for Exponential BackOff implementation

Default Value:

base-second: 2
max-duration: 20s

maxLogMessageLength (int)

Deprecated!!! Max length of error message.

Default Value:

"0"

config.BackOffConfig

base-second (int)

The number of seconds representing the base duration of the exponential backoff

Default Value:

"2"
max-duration ( config.Duration)

The cap of the backoff duration

Default Value:

20s

config.TaskPluginConfig

enabled-plugins ([]string)

Plugins enabled currently

Default Value:

[]
default-for-task-types (map[string]string)

Default Value:

{}

Section: webhook

metrics-prefix (string)

An optional prefix for all published metrics.

Default Value:

'flyte:'

certDir (string)

Certificate directory to use to write generated certs. Defaults to /etc/webhook/certs/

Default Value:

/etc/webhook/certs

localCert (bool)

write certs locally. Defaults to false

Default Value:

"false"

listenPort (int)

The port to use to listen to webhook calls. Defaults to 9443

Default Value:

"9443"

serviceName (string)

The name of the webhook service.

Default Value:

flyte-pod-webhook

servicePort (int32)

The port on the service that hosting webhook.

Default Value:

"443"

secretName (string)

Secret name to write generated certs to.

Default Value:

flyte-pod-webhook

secretManagerType (int)

Default Value:

K8s

awsSecretManager ( config.AWSSecretManagerConfig)

AWS Secret Manager config.

Default Value:

resources:
  limits:
    cpu: 200m
    memory: 500Mi
  requests:
    cpu: 200m
    memory: 500Mi
sidecarImage: docker.io/amazon/aws-secrets-manager-secret-sidecar:v0.1.4

gcpSecretManager ( config.GCPSecretManagerConfig)

GCP Secret Manager config.

Default Value:

resources:
  limits:
    cpu: 200m
    memory: 500Mi
  requests:
    cpu: 200m
    memory: 500Mi
sidecarImage: gcr.io/google.com/cloudsdktool/cloud-sdk:alpine

vaultSecretManager ( config.VaultSecretManagerConfig)

Vault Secret Manager config.

Default Value:

annotations: null
kvVersion: "2"
role: flyte

config.AWSSecretManagerConfig

sidecarImage (string)

Specifies the sidecar docker image to use

Default Value:

docker.io/amazon/aws-secrets-manager-secret-sidecar:v0.1.4
resources ( v1.ResourceRequirements)

Default Value:

limits:
  cpu: 200m
  memory: 500Mi
requests:
  cpu: 200m
  memory: 500Mi

v1.ResourceRequirements

limits (v1.ResourceList)

Default Value:

cpu: 200m
memory: 500Mi
requests (v1.ResourceList)

Default Value:

cpu: 200m
memory: 500Mi
claims ([]v1.ResourceClaim)

Default Value:

null

config.GCPSecretManagerConfig

sidecarImage (string)

Specifies the sidecar docker image to use

Default Value:

gcr.io/google.com/cloudsdktool/cloud-sdk:alpine
resources ( v1.ResourceRequirements)

Default Value:

limits:
  cpu: 200m
  memory: 500Mi
requests:
  cpu: 200m
  memory: 500Mi

config.VaultSecretManagerConfig

role (string)

Specifies the vault role to use

Default Value:

flyte
kvVersion (int)

Default Value:

"2"
annotations (map[string]string)

Default Value:

null