o Df @sdZddlZddlZddlZddlmZddlmZmZm Z ddl m Z e ej e ddZdd Zdd d Zd ddZe ejfddZejededejdeddddejdeddddejdeddddddZdS)!zGThe ``celery upgrade`` command, used to upgrade from previous versions.N)defaults) CeleryCommand CeleryOptionhandle_preload_options)pass1cCsdS)z!Perform upgrade between versions.N)ctxrrK/home/ubuntu/webapp/venv/lib/python3.10/site-packages/celery/bin/upgrade.pyupgrade sr cCs@t|dd}dd|DWdS1swYdS)Nrutf-8cSsg|]}|qSrr.0linerrr sz_slurp..)codecsopen)filenameread_fhrrr _slurps $rCELERYcCs$|}||sd||g}|S)N_)upper startswithjoin)key namespacerrr _compat_keys r.origc Csg}d||g}td|dtjdt|dd7}t|dd}|D] }||||q&Wdn1s=wYWd|SWd|S1sUwY|S)Nzwriting backup to ...filer r w)rprintsysstderrrrwriteappend)rsuffixlinesbackup_filenamer backup_fhrrrr _backup s&     r-cCsRtt|dddD]}|||||}||kr$d|vr$d|fSq d|fS)NcSst|S)N)len)xrrr 0sz_to_new_key..)r CELERY_CELERYr)reversedsortedreplace)r keyfiltersourceold_keynew_linerrr _to_new_key-s  r:)clsrz--djangoTzUpgrading OptionszUpgrade Django project.)r;is_flag help_grouphelpz--compatz!Maintain backwards compatibility.z --no-backupzDon't backup original files.c st|}|s|r tnttd|dtjdfdd|D}tdd|Dr[|s/t|t |dd }|D] \}}| |q9Wd n1sMwYtd tj dd Std tj dd S) z/Migrate settings from Celery 3.x to Celery 4.x.z processing r r!csg|]}t|qSr)r:r r6rr rNs zsettings..css|]}|dVqdS)rNr)rnrrr Qszsettings..r#r Nz'Changes to your setting have been made!z(Does not seem to require any changes :-)) rrrr$r%r&anyr-rrr'stdout) rdjangocompat no_backupr* new_lineswrite_fhrrrr?r settings7s(     rI)r)r)__doc__rr%click celery.apprcelery.bin.baserrrcelery.utils.functionalrgroup pass_contextr rrr- _TO_NEW_KEYr:commandargumentoptionrIrrrr sH