https://dagster.io/ logo
Title
t

Tadas Barzdžius

08/09/2021, 4:02 PM
Any pointers how I should mount volumes on job pods with K8sRunLauncher?
r

rex

08/09/2021, 5:25 PM
This is currently not supported, here’s the relevant issue https://github.com/dagster-io/dagster/issues/3871
t

Tadas Barzdžius

08/09/2021, 5:49 PM
Aw, snap… This kills my experimentation with dagster 😞
@rex any progress here? 🙂
r

rex

09/28/2021, 8:16 AM
t

Tadas Barzdžius

09/28/2021, 10:35 AM
Nice, thanks. Eagerly looking forward to it.
Hey @rex, I’m trying volumes implementation now, but I can’t get it to work. I’m defining volumes and volumeMounts with dagster helm values file:
volumes:
        - name: storage
          cephfs:
            monitors:
              - ip1
              - ip2
              - ip3
              - ip4
              - ip5
            path: /storage
            secretRef:
              name: super-secret-secret
            user: storage
      volumeMounts:
        - name: storage
          mountPath: /mnt/storage
And I get:
AttributeError: module 'kubernetes.client.models' has no attribute 'list[str]'
  File "/usr/local/lib/python3.7/site-packages/dagster/core/instance/__init__.py", line 1502, in launch_run
    self._run_launcher.launch_run(LaunchRunContext(pipeline_run=run, workspace=workspace))
  File "/usr/local/lib/python3.7/site-packages/dagster_k8s/launcher.py", line 312, in launch_run
    user_defined_k8s_config=user_defined_k8s_config,
  File "/usr/local/lib/python3.7/site-packages/dagster_k8s/job.py", line 587, in construct_dagster_k8s_job
    volume,
  File "/usr/local/lib/python3.7/site-packages/dagster_k8s/models.py", line 51, in k8s_model_from_dict
    kwargs[attr] = _k8s_value(value, attr_type, mapped_attr)
  File "/usr/local/lib/python3.7/site-packages/dagster_k8s/models.py", line 31, in _k8s_value
    return k8s_model_from_dict(klass, data)
  File "/usr/local/lib/python3.7/site-packages/dagster_k8s/models.py", line 51, in k8s_model_from_dict
    kwargs[attr] = _k8s_value(value, attr_type, mapped_attr)
  File "/usr/local/lib/python3.7/site-packages/dagster_k8s/models.py", line 15, in _k8s_value
    klass = getattr(kubernetes.client.models, classname)
What am I doing incorrectly?