from background_task import background

from apps.station.serializers.station_serializers import StationCSVUploadSerializers


@background(schedule=0, queue="upload-station-csv")
def upload_station_csv_data(data, user_id):
    serializer = StationCSVUploadSerializers(
        data=data, many=True, context={"user": user_id}
    )

    if serializer.is_valid():
        serializer.save(is_verified=True)