Please enable JavaScript.

Coggle requires JavaScript to display documents.

Trigger a new Dag Run dag.py, preprocessing_files preprocessed_dir …

- - - - output_path = output_dir / data["flight_id"] / "inputs"
        
        create this output_path dir
        
        create output file in the output_path dir with
        same name as file present in inbox
        literally moving the file from inbox to output(data) folder
        with aircraft details as folder structure
        make appropriate changes in map we have from extract_data_from_file method and append to a list
        at the end return this list of maps
        
        List Of Maps
      - you will get data
        a map with all the flight data extracted from this file
    - - splits given file path by _
        A valid input file
        should split into 9 parts
        
        uuid in hexa
        msn with the 7th split,
        taking only digits
        
        Overall it generates a map like
        this from a given filename
        
        "flight_id": uuid,
        
        "flightcode": filename.stem.split("", 1)[1],
        
        "airline": splits[1],
        
        "aircraft": splits[2],
        
        "time": splits[8].split(".")[0],
        
        "MSN": msn,
- - - - "{{ var.value.pre_taxi_script }} -INPUT_FILE $file" " -EVENT taxi -PCD {{ var.value.ground_pcd }}"