from dagster import job, op
from dagster_shell import shell_op

@op
def shell_greeting():
    return 'echo "this is a test message"'

@op
def show_output(msg):
    print("The output was: " + msg)

@job()
def shell_hello_job():
    show_output(shell_op(shell_greeting()))

if __name__ == "__main__":
    result = shell_hello_job.execute_in_process()