Peter Arwanitis
04/23/2023, 5:35 PMops:
'*':
config:
base_url: '<http://localhost:8000>'
monitor_web_service:
config:
default_max_retries: 3
which I then plan to use like this
@op(config_schema={
'default_max_retries': int,
'base_url': Field(StringSource)
})
def monitor_web_service(context, job_name: str, job_id: str, max_retries: Optional[int]):
# from dagster.yaml
default_max_retries = context.op_config['default_max_retries']
base_url = context.op_config['base_url']
my concrete problem is:
• where to add this configuration or reference the yaml file?
• in dagster.yaml
=> no, in workspace.yanl
=> I don't think so either
• on commandline using dagster dev
there is no -c config.yaml
support
how? Where is the documentation explaining all config options in detail (dagster / workspace / custom ..)?
thank you for pointers! 🙂sandy
04/24/2023, 4:36 PMPeter Arwanitis
04/25/2023, 10:00 PMdo you mind linking to the documentation?that is actually one of my problems 🙂 I can see from examples, that
dagster.yaml
, workspace.yaml
exists
• but doc search lead to this, where I'm looking for a doc explaining the purpose and all features
• same applies to workspace.yaml
=> purpose, supported fields?
solution:
• a full featured version of the system yamls might be good, with inline comments
and in the mean-time I understood that there is a config, which can be added for "run time" in launchpad (or programmatically)
• the "Run Configuration" doc section (link) is okstart_webservice
with parameters
• with dependencies supporting fan-in and -out
• the op starts a webservice and waits until completion
• when it ends a depended op
in the graph can be started
but the doc-chapter config and implementation is a custom implementation
• which I'm not able to extend to the degree of creating op
from a factory
• which I can connect (dependencies) in a graph like so
the variable number of input-dependencies is killing me as @op(ins={"start": *In*(Nothing)})
seems to be needed, but don't support fan-in?
sry, sounds very confusing me trying to abuse(?) dagster?
And it is the third night me experimenting (and treating chatgpt as a source of inspiration, which fails as it is mostly stuck with old 0.12 versions)
api:
base_url: '<http://localhost:8000>'
default_max_retries: 3
ops:
- name: job1
depends_on: []
max_retries: 3
- name: job2
max_retries: 2
- name: job3
depends_on: [job1, job2]
max_retries: 1
- name: job4
depends_on: [job3]
max_retries: 0