@@ -572,6 +572,10 @@ def compile(self, patterns):
572
572
rules .append ((None , r ))
573
573
self ._rules = rules
574
574
575
+ def reset (self ):
576
+ self ._log .debug ("reset filter patterns" )
577
+ self ._rules = None
578
+
575
579
def filter (self , path , prefix = None ):
576
580
path = os .path .normpath (path )
577
581
if prefix :
@@ -883,6 +887,8 @@ def commands_step(path, commands):
883
887
return build_plan
884
888
885
889
def execute (self , build_plan , zip_stream , query ):
890
+ sh_log = logging .getLogger ("sh" )
891
+
886
892
tf_work_dir = os .getcwd ()
887
893
888
894
zs = zip_stream
@@ -896,7 +902,7 @@ def execute(self, build_plan, zip_stream, query):
896
902
source_path , prefix = action [1 :]
897
903
if not sh_work_dir :
898
904
sh_work_dir = tf_work_dir
899
- log .info ("WORKDIR: %s" , sh_work_dir )
905
+ log .debug ("WORKDIR: %s" , sh_work_dir )
900
906
if source_path :
901
907
if not os .path .isabs (source_path ):
902
908
source_path = os .path .join (sh_work_dir , source_path )
@@ -955,6 +961,11 @@ def execute(self, build_plan, zip_stream, query):
955
961
if not os .path .isabs (path ):
956
962
path = os .path .join (tf_work_dir , path )
957
963
964
+ if log .isEnabledFor (DEBUG2 ):
965
+ log .debug ("exec shell script ..." )
966
+ for line in script .splitlines ():
967
+ sh_log .debug (line )
968
+
958
969
script = "\n " .join (
959
970
(
960
971
script ,
@@ -974,17 +985,9 @@ def execute(self, build_plan, zip_stream, query):
974
985
cwd = path ,
975
986
)
976
987
977
- p .wait ()
978
- temp_file .seek (0 )
979
-
980
- # NOTE: This var `sh_work_dir` is consumed in cmd == "zip" loop
981
- sh_work_dir = temp_file .read ().strip ()
982
-
983
- log .info ("WORKDIR: %s" , sh_work_dir )
984
-
985
988
call_stdout , call_stderr = p .communicate ()
986
989
exit_code = p .returncode
987
- log .info ("exit_code: %s" , exit_code )
990
+ log .debug ("exit_code: %s" , exit_code )
988
991
if exit_code != 0 :
989
992
raise RuntimeError (
990
993
"Script did not run successfully, exit code {}: {} - {}" .format (
@@ -993,13 +996,21 @@ def execute(self, build_plan, zip_stream, query):
993
996
call_stderr .decode ("utf-8" ).strip (),
994
997
)
995
998
)
999
+
1000
+ temp_file .seek (0 )
1001
+ # NOTE: This var `sh_work_dir` is consumed in cmd == "zip" loop
1002
+ sh_work_dir = temp_file .read ().strip ()
1003
+ log .debug ("WORKDIR: %s" , sh_work_dir )
1004
+
996
1005
elif cmd == "reset:workdir" :
997
1006
sh_work_dir = tf_work_dir
1007
+ log .debug ("WORKDIR: %s" , sh_work_dir )
998
1008
elif cmd == "set:filter" :
999
1009
patterns = action [1 ]
1000
1010
pf = ZipContentFilter (args = self ._args )
1001
1011
pf .compile (patterns )
1002
1012
elif cmd == "clear:filter" :
1013
+ pf .reset ()
1003
1014
pf = None
1004
1015
1005
1016
@staticmethod
0 commit comments