-
Notifications
You must be signed in to change notification settings - Fork 10
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
9 changed files
with
184 additions
and
17 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -26,8 +26,8 @@ jobs: | |
|
||
notify: | ||
runs-on: ubuntu-latest | ||
needs: [run-daily-tests, run-daily-doc-link-checks] | ||
if: ${{ always() && contains(needs.*.result, 'failure') }} | ||
needs: [run-daily-tests, run-daily-doc-link-checks, test-dandi-latest, test-dandi-dev, test-dandi-dev-live] | ||
if: failure() | ||
steps: | ||
- uses: dawidd6/action-send-mail@v3 | ||
with: | ||
|
@@ -36,6 +36,6 @@ jobs: | |
username: ${{ secrets.MAIL_USERNAME }} | ||
password: ${{ secrets.MAIL_PASSWORD }} | ||
subject: NWB Inspector Daily Failure | ||
to: ${{ secrets.DAILY_FAILURE_EMAIL_LIST }} # add more with commas, no separation | ||
to: [email protected],[email protected] | ||
from: NWB Inspector | ||
body: "The daily workflow for the NWB Inspector failed: please check status at https://github.com/NeurodataWithoutBorders/nwbinspector/actions/workflows/dailies.yml" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,147 @@ | ||
"""Primary functions for inspecting NWBFiles.""" | ||
|
||
import os | ||
import re | ||
import json | ||
from pathlib import Path | ||
from typing import Optional | ||
from warnings import warn | ||
|
||
import click | ||
|
||
from ._formatting import _get_report_header, InspectorOutputJSONEncoder | ||
from ._types import Importance | ||
from ._nwb_inspection import inspect_all | ||
from ._formatting import format_messages, print_to_console, save_report, InspectorOutputJSONEncoder | ||
from ._version import __version__ | ||
from ._configuration import load_config | ||
from .utils import strtobool | ||
|
||
|
||
@click.command() | ||
@click.argument("path") | ||
@click.option("--modules", help="Modules to import prior to reading the file(s).") | ||
@click.option( | ||
"--report-file-path", | ||
default=None, | ||
help="Save path for the report file.", | ||
type=click.Path(writable=True), | ||
) | ||
@click.option("--levels", help="Comma-separated names of InspectorMessage attributes to organize by.") | ||
@click.option( | ||
"--reverse", help="Comma-separated booleans corresponding to reversing the order for each value of 'levels'." | ||
) | ||
@click.option("--overwrite", help="Overwrite an existing report file at the location.", is_flag=True) | ||
@click.option("--ignore", help="Comma-separated names of checks to skip.") | ||
@click.option("--select", help="Comma-separated names of checks to run.") | ||
@click.option( | ||
"--threshold", | ||
default="BEST_PRACTICE_SUGGESTION", | ||
type=click.Choice(["CRITICAL", "BEST_PRACTICE_VIOLATION", "BEST_PRACTICE_SUGGESTION"]), | ||
help="Ignores tests with an assigned importance below this threshold.", | ||
) | ||
@click.option("--config", help="Name of config or path of config .yaml file that overwrites importance of checks.") | ||
@click.option("--json-file-path", help="Write json output to this location.") | ||
@click.option("--n-jobs", help="Number of jobs to use in parallel.", default=1) | ||
@click.option("--skip-validate", help="Skip the PyNWB validation step.", is_flag=True) | ||
@click.option( | ||
"--detailed", | ||
help=( | ||
"If file_path is the last of 'levels' (the default), identical checks will be aggregated in the display. " | ||
"Use '--detailed' to see the complete report." | ||
), | ||
is_flag=True, | ||
) | ||
@click.option("--progress-bar", help="Set this flag to False to disable display of the progress bar.") | ||
@click.option( | ||
"--stream", | ||
help=( | ||
"Stream data from the DANDI archive. If the 'path' is a local copy of the target DANDISet, specifying this " | ||
"flag will still force the data to be streamed instead of using the local copy. To use the local copy, simply " | ||
"remove this flag. Requires the Read Only S3 (ros3) driver to be installed with h5py." | ||
), | ||
is_flag=True, | ||
) | ||
@click.option( | ||
"--version-id", | ||
help=( | ||
"When 'path' is a six-digit DANDISet ID, this further specifies which version of " "the DANDISet to inspect." | ||
), | ||
) | ||
@click.version_option(__version__) | ||
def _inspect_all_cli( | ||
path: str, | ||
modules: Optional[str] = None, | ||
report_file_path: str = None, | ||
levels: str = None, | ||
reverse: Optional[str] = None, | ||
overwrite: bool = False, | ||
ignore: Optional[str] = None, | ||
select: Optional[str] = None, | ||
threshold: str = "BEST_PRACTICE_SUGGESTION", | ||
config: Optional[str] = None, | ||
json_file_path: Optional[str] = None, | ||
n_jobs: int = 1, | ||
skip_validate: bool = False, | ||
detailed: bool = False, | ||
progress_bar: Optional[str] = None, | ||
stream: bool = False, | ||
version_id: Optional[str] = None, | ||
): | ||
""" | ||
Run the NWBInspector via the command line. | ||
path : | ||
Path to either a local NWBFile, a local folder containing NWBFiles, a link to a dataset on | ||
DANDI archive (i.e., https://dandiarchive.org/dandiset/{dandiset_id}/{version_id}), or a six-digit Dandiset ID. | ||
""" | ||
levels = ["importance", "file_path"] if levels is None else levels.split(",") | ||
modules = [] if modules is None else modules.split(",") | ||
reverse = [False] * len(levels) if reverse is None else [strtobool(x) for x in reverse.split(",")] | ||
progress_bar = strtobool(progress_bar) if progress_bar is not None else True | ||
if config is not None: | ||
config = load_config(filepath_or_keyword=config) | ||
if stream: | ||
url_path = path if path.startswith("https://") else None | ||
if url_path: | ||
dandiset_id, version_id = url_path.split("/")[-2:] | ||
path = dandiset_id | ||
assert url_path or re.fullmatch( | ||
pattern="^[0-9]{6}$", string=path | ||
), "'--stream' flag was enabled, but 'path' is neither a full link to the DANDI archive nor a DANDISet ID." | ||
if Path(path).is_dir(): | ||
warn( | ||
f"The local DANDISet '{path}' exists, but the '--stream' flag was used. " | ||
"NWBInspector will use S3 streaming from DANDI. To use local data, remove the '--stream' flag." | ||
) | ||
messages = list( | ||
inspect_all( | ||
path=path, | ||
modules=modules, | ||
ignore=ignore if ignore is None else ignore.split(","), | ||
select=select if select is None else select.split(","), | ||
importance_threshold=Importance[threshold], | ||
config=config, | ||
n_jobs=n_jobs, | ||
skip_validate=skip_validate, | ||
progress_bar=progress_bar, | ||
stream=stream, | ||
version_id=version_id, | ||
) | ||
) | ||
if json_file_path is not None: | ||
if Path(json_file_path).exists() and not overwrite: | ||
raise FileExistsError(f"The file {json_file_path} already exists! Specify the '-o' flag to overwrite.") | ||
with open(file=json_file_path, mode="w") as fp: | ||
json_report = dict(header=_get_report_header(), messages=messages) | ||
json.dump(obj=json_report, fp=fp, cls=InspectorOutputJSONEncoder) | ||
print(f"{os.linesep*2}Report saved to {str(Path(json_file_path).absolute())}!{os.linesep}") | ||
formatted_messages = format_messages(messages=messages, levels=levels, reverse=reverse, detailed=detailed) | ||
print_to_console(formatted_messages=formatted_messages) | ||
if report_file_path is not None: | ||
save_report(report_file_path=report_file_path, formatted_messages=formatted_messages, overwrite=overwrite) | ||
print(f"{os.linesep*2}Report saved to {str(Path(report_file_path).absolute())}!{os.linesep}") | ||
|
||
|
||
if __name__ == "__main__": | ||
_inspect_all_cli() |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters