(ctx context.Context, a *wfv1.Artifact)
| 207 | } |
| 208 | |
| 209 | func (g *ArtifactDriver) OpenStream(ctx context.Context, a *wfv1.Artifact) (io.ReadCloser, error) { |
| 210 | // todo: this is a temporary implementation which loads file to disk first |
| 211 | return common.LoadToStream(ctx, a, g) |
| 212 | } |
| 213 | |
| 214 | func (g *ArtifactDriver) ListObjects(ctx context.Context, artifact *wfv1.Artifact) ([]string, error) { |
| 215 | return nil, fmt.Errorf("ListObjects is currently not supported for this artifact type, but it will be in a future version") |
nothing calls this directly
no test coverage detected