@@ -1524,7 +1524,7 @@ def get_file_category(self, category):
15241524 # Things to consider for files:
15251525 # - How can you download / stream a file?
15261526 # - Can you decide if you want a stream or the files directly?
1527- def get_file (self , value ):
1527+ def get_file (self , value , category = "" ):
15281528 full_execution = self .full_execution
15291529 org_id = full_execution ["workflow" ]["execution_org" ]["id" ]
15301530
@@ -1805,6 +1805,18 @@ def set_files(self, infiles):
18051805 self .logger .info (f"KeyError in file setup: { e } " )
18061806 pass
18071807
1808+ try :
1809+ data ["namespace" ] = curfile ["namespace" ]
1810+ except KeyError as e :
1811+ #self.logger.info(f"KeyError in file setup for namespace: {e}")
1812+ pass
1813+
1814+ try :
1815+ data ["namespace" ] = curfile ["category" ]
1816+ except KeyError as e :
1817+ #self.logger.info(f"KeyError in file setup for category: {e}")
1818+ pass
1819+
18081820 ret = requests .post ("%s%s" % (self .url , create_path ), headers = headers , json = data , verify = False , proxies = self .proxy_config )
18091821 #self.logger.info(f"Ret CREATE: {ret.text}")
18101822 cur_id = ""
@@ -2071,6 +2083,8 @@ def execute_action(self, action):
20712083 if newkey .startswith ("'" ) and newkey .endswith ("'" ):
20722084 newkey = newkey [1 :- 1 ]
20732085
2086+ print ("KEY: %s" % newkey )
2087+
20742088 if newkey == "shuffle_authorization" :
20752089 self .authorization = keysplit [1 ]
20762090 continue
0 commit comments