diff --git a/utils/mqtt_rider_convert/mqtt_rider_convert.py b/utils/mqtt_rider_convert/mqtt_rider_convert.py index 8f97a04a..6dc6ad18 100644 --- a/utils/mqtt_rider_convert/mqtt_rider_convert.py +++ b/utils/mqtt_rider_convert/mqtt_rider_convert.py @@ -70,4 +70,4 @@ def on_message(client, userdata, message): client.publish(channel, payload) # add to rider_cache rider's latest location - redis_conn.geoadd('loc_rider_active', rider_log, rider_lat, rider_id) + redis_conn.geoadd('loc_rider_active', rider_long, rider_lat, rider_id)