Piotr Danielczyk
06/13/2023, 4:26 PMtag
"dagster/priority"
of an aliased op()
? I tried setting it via job run config but it failed. Is the only option to set it in `op()`'s decorator (it does not work in case of .alias()
?
EDIT: when I try to set it in the run config like this:
clients_to_crm.execute_in_process(
{
"ops": {
"save_clients": { # this is the aliased op
"tags": {"dagster/priority": "98"},
"config": {
"table_name": "my_custom_config_that_i_also_use",
},
}
},
},
)
I get such error or similar:
Error 1: Received unexpected config entry "tags" at path rootopssave_clients. Expected: "{ config: { table_name: (String | { env: String }) } }".
Gustavo Carvalho
06/13/2023, 4:32 PMPiotr Danielczyk
06/13/2023, 4:58 PMtags
when passing data to the config. The code looks like this:
clients_to_crm.execute_in_process(
{
"ops": {
"save_clients": { # this is the aliased op
"tags": {"dagster/priority": "98"},
"config": {
"table_name": "my_custom_config_that_i_also_use",
},
}
},
},
)
While the graph looks like this:
@graph()
def clients_to_crm():
save_to_crm.alias("save_clients")()
Piotr Danielczyk
06/13/2023, 4:59 PMError 1: Received unexpected config entry "tags" at path root:ops:save_clients. Expected: "{ config: { table_name: (String | { env: String }) } }".
Gustavo Carvalho
06/13/2023, 5:11 PMGustavo Carvalho
06/13/2023, 5:12 PMowen
06/13/2023, 5:56 PM