def clean_airports(airports_spark, spark_session):
    """
    Clean data from airports
    
    Args:
        airports_spark (object): Pyspark dataframe object
        spark_session (object): Pyspark session
        
    Returns:
        (object): Pyspark dataframe with cleaned data
    """
    spark = spark_session
    airports_spark.createOrReplaceTempView('airports')
    
    airports_spark_cleaned = spark.sql("""
    SELECT ident, name, municipality as City, SUBSTRING(iso_region, 4, 5) as State, iata_code
    FROM airports
    WHERE iata_code IS NOT NULL
    """)

    airports_spark_cleaned = airports_spark_cleaned.dropDuplicates()
    airports_spark_cleaned = airports_spark_cleaned.na.drop()
    
    return airports_spark_cleaned