Kyle Gobel
10/24/2022, 4:06 AMop
based on the output of a different op
from dagster import op, graph
from dagster_k8s import k8s_job_op
@op
def get_greeting():
return "hello"
@graph
def my_graph():
greeting = get_greeting()
greeter = k8s_job_op.configured(
{
"image": "busybox",
"command": ["/bin/sh", "-c"],
"args": ["echo " + greeting], #obv this doesn't work, but not sure what to do
"load_incluster_config": False,
"namespace": "default"
},
name="say_greeting"
)
greeter()
k8s_job_op
essentially) -- but was hoping maybe there's a better way