Sundara Moorthy
02/24/2022, 10:02 AMdagster-user-deployments:
enabled: true
deployments:
- name: "k8s-example-user-code-1"
image:
repository: "<http://docker.io/dagster/user-code-example|docker.io/dagster/user-code-example>"
tag: latest
pullPolicy: Always
dagsterApiGrpcArgs:
- "--python-file"
- "/example_project/example_repo/repo.py"
port: 3030
Can i use spark image in place of docker.io/dagster/user-code-examplealex
02/24/2022, 3:16 PMSundara Moorthy
02/24/2022, 3:18 PMdagster-user-deployments:
enabled: true
deployments:
- name: "k8s-example-user-code-1"
image:
repository: "<http://docker.io/bitnami/spark-3.1.2|docker.io/bitnami/spark-3.1.2>"
tag: latest
pullPolicy: Always
dagsterApiGrpcArgs:
- spark-submit --master <k8s://https>://<k8s-apiserver-host>:<k8s-apiserver-port> \
--deploy-mode cluster
- "/example_project/example_repo/repo.py"
port: 3030
alex
02/24/2022, 3:20 PM@repository
and the `@job`s & etc it contains.
Why are you trying to spark-submit
from there?Sundara Moorthy
02/24/2022, 3:23 PMalex
02/24/2022, 3:25 PM@resource
or @op
what you posted above certainly wont work since you are passing the spark-submit
command as a cli flag to dagster api grpc
in the dagsterApiGrpcArgs
sectionSundara Moorthy
02/24/2022, 3:27 PMdagster-user-deployments:
enabled: true
deployments:
- name: "code"
image:
repository: "<http://docker.io/code/code|docker.io/code/code>"
tag: latest
pullPolicy: Always
dagsterApiGrpcArgs:
- "--python-file"
- "/main.py"
port: 3030
alex
02/24/2022, 3:39 PMuser-deployment
. The same image will be used with @job
s are run that were sourced from that deployment.Sundara Moorthy
02/24/2022, 3:40 PMalex
02/24/2022, 3:45 PMSundara Moorthy
02/24/2022, 3:47 PMalex
02/24/2022, 3:48 PMschedule
or sensor
or use the GraphQL API to programtically trigger runsSundara Moorthy
02/24/2022, 3:48 PM