Pablo Beltran
04/08/2023, 1:14 AMZach
04/08/2023, 1:33 AM@op(required_resource_keys={"remote_launcher"}
def remote_execute():
pass
@op
def local_execute():
pass
@job(resource_defs={"remote_launcher": step_launcher_instance"})
def job():
remote_execute()
local_execute()
Dagster inspects the resources for each op and knows to use the step launcher if an op has a step launcher configured for a resourceZach
04/08/2023, 1:33 AMPablo Beltran
04/08/2023, 1:48 AMsandy
04/10/2023, 3:53 PM