scheduler

Apache Airflow version

2.0.0

What happened

using ftphook, im trying to download a file in chunks but the deafult blocksize is 8192 and cannot be changed.
retrieve_file code is calling conn.retrbinary(f'RETR {remote_file_name}', callback) but no blocksize is passed while this function is declared:
def retrbinary(self, cmd, callback, blocksize=8192, rest=None):

What you think

Is there a way to make a job re-occur N milliseconds after it finished previous time?