started defining data pipeline - not currently compilable