mirror of https://github.com/databricks/cli.git
Compare commits
1 Commits
9c5c2b0648
...
3a15c6e6b6
Author | SHA1 | Date |
---|---|---|
Andrew Nester | 3a15c6e6b6 |
|
@ -723,63 +723,6 @@ func TestAccWorkspaceFilesExtensionsDirectoriesAreNotNotebooks(t *testing.T) {
|
||||||
assert.ErrorIs(t, err, fs.ErrNotExist)
|
assert.ErrorIs(t, err, fs.ErrNotExist)
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAccWorkspaceFilesExtensionsNotebooksAreNotReadAsFiles(t *testing.T) {
|
|
||||||
t.Parallel()
|
|
||||||
|
|
||||||
ctx := context.Background()
|
|
||||||
wf, _ := setupWsfsExtensionsFiler(t)
|
|
||||||
|
|
||||||
// Create a notebook
|
|
||||||
err := wf.Write(ctx, "foo.ipynb", strings.NewReader(readFile(t, "testdata/notebooks/py1.ipynb")))
|
|
||||||
require.NoError(t, err)
|
|
||||||
|
|
||||||
// Reading foo should fail. Even though the WSFS name for the notebook is foo
|
|
||||||
// reading the notebook should only work with the .ipynb extension.
|
|
||||||
_, err = wf.Read(ctx, "foo")
|
|
||||||
assert.ErrorIs(t, err, fs.ErrNotExist)
|
|
||||||
|
|
||||||
_, err = wf.Read(ctx, "foo.ipynb")
|
|
||||||
assert.NoError(t, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestAccWorkspaceFilesExtensionsNotebooksAreNotStatAsFiles(t *testing.T) {
|
|
||||||
t.Parallel()
|
|
||||||
|
|
||||||
ctx := context.Background()
|
|
||||||
wf, _ := setupWsfsExtensionsFiler(t)
|
|
||||||
|
|
||||||
// Create a notebook
|
|
||||||
err := wf.Write(ctx, "foo.ipynb", strings.NewReader(readFile(t, "testdata/notebooks/py1.ipynb")))
|
|
||||||
require.NoError(t, err)
|
|
||||||
|
|
||||||
// Stating foo should fail. Even though the WSFS name for the notebook is foo
|
|
||||||
// stating the notebook should only work with the .ipynb extension.
|
|
||||||
_, err = wf.Stat(ctx, "foo")
|
|
||||||
assert.ErrorIs(t, err, fs.ErrNotExist)
|
|
||||||
|
|
||||||
_, err = wf.Stat(ctx, "foo.ipynb")
|
|
||||||
assert.NoError(t, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestAccWorkspaceFilesExtensionsNotebooksAreNotDeletedAsFiles(t *testing.T) {
|
|
||||||
t.Parallel()
|
|
||||||
|
|
||||||
ctx := context.Background()
|
|
||||||
wf, _ := setupWsfsExtensionsFiler(t)
|
|
||||||
|
|
||||||
// Create a notebook
|
|
||||||
err := wf.Write(ctx, "foo.ipynb", strings.NewReader(readFile(t, "testdata/notebooks/py1.ipynb")))
|
|
||||||
require.NoError(t, err)
|
|
||||||
|
|
||||||
// Deleting foo should fail. Even though the WSFS name for the notebook is foo
|
|
||||||
// deleting the notebook should only work with the .ipynb extension.
|
|
||||||
err = wf.Delete(ctx, "foo")
|
|
||||||
assert.ErrorIs(t, err, fs.ErrNotExist)
|
|
||||||
|
|
||||||
err = wf.Delete(ctx, "foo.ipynb")
|
|
||||||
assert.NoError(t, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestAccWorkspaceFilesExtensions_ExportFormatIsPreserved(t *testing.T) {
|
func TestAccWorkspaceFilesExtensions_ExportFormatIsPreserved(t *testing.T) {
|
||||||
t.Parallel()
|
t.Parallel()
|
||||||
|
|
||||||
|
|
|
@ -244,17 +244,6 @@ func (w *workspaceFilesExtensionsClient) Write(ctx context.Context, name string,
|
||||||
|
|
||||||
// Try to read the file as a regular file. If the file is not found, try to read it as a notebook.
|
// Try to read the file as a regular file. If the file is not found, try to read it as a notebook.
|
||||||
func (w *workspaceFilesExtensionsClient) Read(ctx context.Context, name string) (io.ReadCloser, error) {
|
func (w *workspaceFilesExtensionsClient) Read(ctx context.Context, name string) (io.ReadCloser, error) {
|
||||||
// Ensure that the file / notebook exists. We do this check here to avoid reading
|
|
||||||
// the content of a notebook called `foo` when the user actually wanted
|
|
||||||
// to read the content of a file called `foo`.
|
|
||||||
//
|
|
||||||
// To read the content of a notebook called `foo` in the workspace the user
|
|
||||||
// should use the name with the extension included like `foo.ipynb` or `foo.sql`.
|
|
||||||
_, err := w.Stat(ctx, name)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
r, err := w.wsfs.Read(ctx, name)
|
r, err := w.wsfs.Read(ctx, name)
|
||||||
|
|
||||||
// If the file is not found, it might be a notebook.
|
// If the file is not found, it might be a notebook.
|
||||||
|
@ -287,18 +276,7 @@ func (w *workspaceFilesExtensionsClient) Delete(ctx context.Context, name string
|
||||||
return ReadOnlyError{"delete"}
|
return ReadOnlyError{"delete"}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Ensure that the file / notebook exists. We do this check here to avoid
|
err := w.wsfs.Delete(ctx, name, mode...)
|
||||||
// deleting the a notebook called `foo` when the user actually wanted to
|
|
||||||
// delete a file called `foo`.
|
|
||||||
//
|
|
||||||
// To delete a notebook called `foo` in the workspace the user should use the
|
|
||||||
// name with the extension included like `foo.ipynb` or `foo.sql`.
|
|
||||||
_, err := w.Stat(ctx, name)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
err = w.wsfs.Delete(ctx, name, mode...)
|
|
||||||
|
|
||||||
// If the file is not found, it might be a notebook.
|
// If the file is not found, it might be a notebook.
|
||||||
if errors.As(err, &FileDoesNotExistError{}) {
|
if errors.As(err, &FileDoesNotExistError{}) {
|
||||||
|
@ -337,24 +315,7 @@ func (w *workspaceFilesExtensionsClient) Stat(ctx context.Context, name string)
|
||||||
return wsfsFileInfo{ObjectInfo: stat.ObjectInfo}, nil
|
return wsfsFileInfo{ObjectInfo: stat.ObjectInfo}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if err != nil {
|
return info, err
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
// If an object is found and it is a notebook, return a FileDoesNotExistError.
|
|
||||||
// If a notebook is found by the workspace files client, without having stripped
|
|
||||||
// the extension, this implies that no file with the same name exists.
|
|
||||||
//
|
|
||||||
// This check is done to avoid returning the stat for a notebook called `foo`
|
|
||||||
// when the user actually wanted to stat a file called `foo`.
|
|
||||||
//
|
|
||||||
// To stat the metadata of a notebook called `foo` in the workspace the user
|
|
||||||
// should use the name with the extension included like `foo.ipynb` or `foo.sql`.
|
|
||||||
if info.Sys().(workspace.ObjectInfo).ObjectType == workspace.ObjectTypeNotebook {
|
|
||||||
return nil, FileDoesNotExistError{name}
|
|
||||||
}
|
|
||||||
|
|
||||||
return info, nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Note: The import API returns opaque internal errors for namespace clashes
|
// Note: The import API returns opaque internal errors for namespace clashes
|
||||||
|
|
Loading…
Reference in New Issue