mirror of
https://github.com/Stone-Red-Code/dvc.git
synced 2026-11-11 15:28:27 +01:00
David RobertsandRuslan Kuprieiev
a664059eff
* status: Show friendly message for empty project. When there are no stages in the repo, show a friendly message to that effect and display a getting-started URL. Fixes #4395. * Fix style check failing due to line too long. (E501) * Use format_link(…) as suggested by @skshetry, vs {blue}/{nc}. Since I'd pulled the old syntax out of repo/init.py, I've fixed that up as well so no one makes that mistake again. Note that this adds <>s around the link text, unlike before: +---------------------------------------------------------------------+ | | | DVC has enabled anonymous aggregate usage analytics. | | Read the analytics documentation (and how to opt-out) here: | | <https://dvc.org/doc/user-guide/analytics> | | | +---------------------------------------------------------------------+ This is probably fine, since if we're going to have a standard link format we might as well stick with it consistently. If we don't like it, we can change format_link() I guess. * Update dvc/command/status.py Co-authored-by: Ruslan Kuprieiev <[email protected]>
78 lines
2.3 KiB
Python
78 lines
2.3 KiB
Python
import logging
|
|
|
|
from dvc.command.data_sync import CmdDataBase
|
|
from dvc.exceptions import DvcException
|
|
from dvc.utils import format_link
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class CmdDataStatus(CmdDataBase):
|
|
STATUS_LEN = 20
|
|
STATUS_INDENT = "\t"
|
|
UP_TO_DATE_MSG = "Data and pipelines are up to date."
|
|
EMPTY_PROJECT_MSG = (
|
|
"There are no data or pipelines tracked in this project yet.\n"
|
|
"See {link} to get started!"
|
|
).format(link=format_link("https://dvc.org/doc/start"))
|
|
|
|
def _normalize(self, s):
|
|
s += ":"
|
|
assert len(s) < self.STATUS_LEN
|
|
return s + (self.STATUS_LEN - len(s)) * " "
|
|
|
|
def _show(self, status, indent=0):
|
|
ind = indent * self.STATUS_INDENT
|
|
|
|
if isinstance(status, str):
|
|
logger.info(f"{ind}{status}")
|
|
return
|
|
|
|
if isinstance(status, list):
|
|
for entry in status:
|
|
self._show(entry, indent)
|
|
return
|
|
|
|
assert isinstance(status, dict)
|
|
|
|
for key, value in status.items():
|
|
if isinstance(value, str):
|
|
logger.info("{}{}{}".format(ind, self._normalize(value), key))
|
|
elif value:
|
|
logger.info(f"{ind}{key}:")
|
|
self._show(value, indent + 1)
|
|
|
|
def run(self):
|
|
indent = 1 if self.args.cloud else 0
|
|
try:
|
|
st = self.repo.status(
|
|
targets=self.args.targets,
|
|
jobs=self.args.jobs,
|
|
cloud=self.args.cloud,
|
|
remote=self.args.remote,
|
|
all_branches=self.args.all_branches,
|
|
all_tags=self.args.all_tags,
|
|
all_commits=self.args.all_commits,
|
|
with_deps=self.args.with_deps,
|
|
recursive=self.args.recursive,
|
|
)
|
|
|
|
if self.args.quiet:
|
|
return bool(st)
|
|
|
|
if self.args.show_json:
|
|
import json
|
|
|
|
logger.info(json.dumps(st))
|
|
elif st:
|
|
self._show(st, indent)
|
|
elif not self.repo.stages:
|
|
logger.info(self.EMPTY_PROJECT_MSG)
|
|
else:
|
|
logger.info(self.UP_TO_DATE_MSG)
|
|
|
|
except DvcException:
|
|
logger.exception("failed to obtain data status")
|
|
return 1
|
|
return 0
|