def createMenuesConsumed()

in bundle_adb_360/src/b_historical/1_createhistbronzeparquets.py [0:0]

• 27 lines of code
• 1 McCabe index (conditional complexity)

def createMenuesConsumed(noofrows=2, mincustid = 1, maxcustid = 10, minrestid = 1, maxrestid = 10) -> DataFrame:
    fs = Fieldset(locale=Locale.EN, i=int(noofrows/2))

    df = pd.DataFrame.from_dict({
        "menueId": fs("increment"),
        "foodName": fs("food.dish"),
        "foodCategory" : 'food',
        "cost": fs("finance.price", minimum=4.99, maximum=222.40),
        "dinnerDate" : fs("datetime.date", start=2022, end=2023),
        "fkcustomer" : fs("numeric.integer_number", start=mincustid, end=maxcustid),
        "fkrestaurant" : fs("numeric.integer_number", start=minrestid, end=maxrestid),
        "fkwaiter" : fs("numeric.integer_number", start=mincustid, end=maxcustid),
        "tableId" : fs("numeric.integer_number", start=5, end=50 )
    })

    df1 = pd.DataFrame.from_dict({
        "menueId": fs("increment"),
        "foodName": fs("food.drink"),
        "foodCategory" : 'beverage',
        "cost": fs("finance.price", minimum=4.99, maximum=222.40),
        "dinnerDate" : fs("datetime.date", start=2022, end=2023),
        "fkcustomer" : fs("numeric.integer_number", start=mincustid, end=maxcustid),
        "fkrestaurant" : fs("numeric.integer_number", start=minrestid, end=maxrestid),
        "fkwaiter" : fs("numeric.integer_number", start=mincustid, end=maxcustid),
        "tableId" : fs("numeric.integer_number", start=5, end=50 )
    })

    sdf = spark.createDataFrame(df)
    sdf1 = spark.createDataFrame(df1)
    return sdf.union(sdf1)