Stone_Red/dvc
1
0
Fork 0
mirror of https://github.com/Stone-Red-Code/dvc.git synced 2026-11-10 15:28:34 +01:00
Code Issues Packages Projects Releases Wiki Activity

RFC: import: pass jobs early

Browse Source 
Signed-off-by: Ruslan Kuprieiev <[email protected]>
This commit is contained in:
Ruslan Kuprieiev
2017-08-27 23:35:22 +03:00
parent 48e18cfc49
commit 1eab71c97f
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dvc/command/import_file.py
+3 -3
View File
@@ -47,7 +47,7 @@ class CmdImportFile(CmdBase):
targets.append((filename, out))
pass
self.import_files(targets, self.parsed_args.lock)
self.import_files(targets, self.parsed_args.lock, self.parsed_args.jobs)
message = 'DVC import files: {} -> {}'.format(str(self.parsed_args.input), output)
self.commit_if_needed(message)
pass
@@ -113,9 +113,9 @@ class CmdImportFile(CmdBase):
return data_targets
def import_files(self, targets, lock=False):
def import_files(self, targets, lock=False, jobs=1):
data_targets = self.collect_targets(targets)
imported_targets = self.cloud.import_data(data_targets, self.parsed_args.jobs)
imported_targets = self.cloud.import_data(data_targets, jobs)
self.create_state_files(imported_targets, lock)
def create_state_files(self, targets, lock):