Snapshot is backed by LMDB not tar files

src/python/pants/engine/fs.py

@@ -52,7 +52,7 @@ def create(relative_to, include, exclude=tuple()):
                      tuple(join(relative_to, f) for f in exclude))
 
 
-class Snapshot(datatype('Snapshot', ['fingerprint', 'path_stats'])):
+class Snapshot(datatype('Snapshot', ['fingerprint', 'digest_length', 'path_stats'])):
   """A Snapshot is a collection of Files and Dirs fingerprinted by their names/content.
 
   Snapshots are used to make it easier to isolate process execution by fixing the contents
@@ -77,7 +77,7 @@ def file_stats(self):
     return [p.stat for p in self.files]
 
   def __repr__(self):
-    return '''Snapshot(fingerprint='{}', entries={})'''.format(hexlify(self.fingerprint)[:8], len(self.path_stats))
+    return '''Snapshot(fingerprint='{}', digest_length='{}', entries={})'''.format(hexlify(self.fingerprint)[:8], self.digest_length, len(self.path_stats))
 
   def __str__(self):
     return repr(self)

src/python/pants/engine/isolated_process.py

@@ -201,18 +201,18 @@ def create_out(product_type, input_selectors, output_conversion):
     return TaskRule(product_type, inputs, func)
 
 
-class ExecuteProcessRequest(datatype('ExecuteProcessRequest', ['argv', 'env'])):
+class ExecuteProcessRequest(datatype('ExecuteProcessRequest', ['argv', 'env', 'input_files_digest', 'digest_length'])):
   """Request for execution with args and snapshots to extract."""
 
-  def __new__(cls, argv, env):
+  def __new__(cls, argv, env, input_files_digest, digest_length):
     """
 
     :param args: Arguments to the process being run.
     :param env: A tuple of environment variables and values.
     """
     if not isinstance(argv, tuple):
       raise ValueError('argv must be a tuple.')
-    return super(ExecuteProcessRequest, cls).__new__(cls, argv, tuple(env))
+    return super(ExecuteProcessRequest, cls).__new__(cls, argv, tuple(env), input_files_digest, digest_length)
 
 
 class ExecuteProcessResult(datatype('ExecuteProcessResult', ['stdout', 'stderr', 'exit_code'])):

src/python/pants/option/options_fingerprinter.py

@@ -14,8 +14,8 @@
 
 from pants.base.build_environment import get_buildroot
 from pants.base.hash_utils import stable_json_hash
-from pants.option.custom_types import (UnsetBool, dict_with_files_option, dir_option,
-                                       file_option, target_option)
+from pants.option.custom_types import (UnsetBool, dict_with_files_option, dir_option, file_option,
+                                       target_option)
 
 
 class Encoder(json.JSONEncoder):

src/rust/engine/Cargo.toml

@@ -21,6 +21,7 @@ cc = "1.0"
 # [workspace]
 
 [dependencies]
+bazel_protos = { path = "process_execution/bazel_protos" }
 boxfuture = { path = "boxfuture" }
 fnv = "1.0.5"
 fs = { path = "fs" }

src/rust/engine/fs/Cargo.toml

@@ -22,7 +22,6 @@ lmdb = "0.7.2"
 ordermap = "0.2.8"
 protobuf = { version = "1.4.1", features = ["with-bytes"] }
 sha2 = "0.6.0"
-tar = "0.4.13"
 tempdir = "0.3.5"
 
 [dev-dependencies]