Replaced all refs to 'cdp = ds[ds.current_pipe]' with 'cdp = pipes.get_pipe()'.
Authored by: bugman 2008-09-29
Parent: [r7445]
Child: [r7447]