Skip to content

Commit

Permalink
Move import guards
Browse files Browse the repository at this point in the history
  • Loading branch information
sjperkins committed Mar 28, 2024
1 parent f399a29 commit 60f42bc
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 10 deletions.
6 changes: 0 additions & 6 deletions daskms/experimental/katdal/__init__.py
Original file line number Diff line number Diff line change
@@ -1,7 +1 @@
try:
import katdal # noqa
except ImportError as e:
raise ImportError("pip install dask-ms[katdal] for katdal support")


from daskms.experimental.katdal.katdal_import import katdal_import
17 changes: 13 additions & 4 deletions daskms/experimental/katdal/katdal_import.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,19 @@
import urllib

import dask
import katdal
from katdal.dataset import DataSet

from daskms.experimental.katdal.msv2_facade import XarrayMSV2Facade
from daskms.experimental.zarr import xds_to_zarr
from daskms.utils import requires

try:
import katdal
from katdal.dataset import DataSet

from daskms.experimental.katdal.msv2_facade import XarrayMSV2Facade
from daskms.experimental.zarr import xds_to_zarr
except ImportError as e:
import_error = e
else:
import_error = None


def default_output_name(url):
Expand All @@ -22,6 +30,7 @@ def default_output_name(url):
return f"{dataset_basename}.zarr"


@requires("pip install dask-ms[katdal]", import_error)
def katdal_import(url: str, out_store: str, no_auto: bool, applycal: str):
if isinstance(url, str):
dataset = katdal.open(url, appycal=applycal)
Expand Down

0 comments on commit 60f42bc

Please sign in to comment.