@@ -1343,44 +1343,3 @@ def __init__(self, name, project):
13431343 def with_input_model (self , model_id ):
13441344 """Sets the input model"""
13451345 return self ._with_input (model_id , self .project .project_key , "model" )
1346-
1347-
1348- class DownloadRecipeCreator (SingleOutputRecipeCreator ):
1349- """
1350- Create a Download recipe
1351- """
1352- def __init__ (self , name , project ):
1353- SingleOutputRecipeCreator .__init__ (self , 'download' , name , project )
1354-
1355-
1356- class RequiredSchemaUpdates (object ):
1357- """
1358- Representation of the updates required to the schema of the outputs of a recipe.
1359- Do not create this class directly, use :meth:`DSSRecipe.compute_schema_updates`
1360- """
1361-
1362- def __init__ (self , recipe , data ):
1363- self .recipe = recipe
1364- self .data = data
1365- self .drop_and_recreate = True
1366- self .synchronize_metastore = True
1367-
1368- def any_action_required (self ):
1369- return self .data ["totalIncompatibilities" ] > 0
1370-
1371- def apply (self ):
1372- results = []
1373- for computable in self .data ["computables" ]:
1374- osu = {
1375- "computableType" : computable ["type" ],
1376- # dirty
1377- "computableId" : computable ["type" ] == "DATASET" and computable ["datasetName" ] or computable ["id" ],
1378- "newSchema" : computable ["newSchema" ],
1379- "dropAndRecreate" : self .drop_and_recreate ,
1380- "synchronizeMetastore" : self .synchronize_metastore
1381- }
1382-
1383- results .append (self .recipe .client ._perform_json ("POST" ,
1384- "/projects/%s/recipes/%s/actions/updateOutputSchema" % (self .recipe .project_key , self .recipe .recipe_name ),
1385- body = osu ))
1386- return results
0 commit comments