Dataflow: Read from Alloy DB

Can anyone help me with writing a dataflow pipeline in Python for reading data in parallel from PostgreSQL hosted in Alloy DB? I have tried with SQLAlchemy but somehow parallelism is not being triggered and only one worker is working making the pipeline super slow.