o
    BVO%  ã                   @   sD   d dl mZ d dlmZ d dlmZ d dlmZ G dd„ deƒZdS )é    )Úabsolute_import)Údb)ÚSchemaMigration)Úconnectionsc                   @   sò  e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd	d
„ Zddidg dddœfdg dddœfdg ddifdg dddœfdœddidg i fdg ddifdg ddifdœi dddi“ddg dddœf“d d!g d"ddd#œf“d$d%g ddd&œf“d'dg d(dif“d)d*g d+dif“d,dg d-d.ddd/œf“d0d%g ddd1œf“d2dg ddif“d3d!g d4ddd#œf“d5dg d6ddœf“d7d%g ddd1œf“d8dg dd.d9œf“d:dg d-d.ddd/œf“d;dg d-d.ddd/œf“d<dg dd.if“d=d>g d+d?if“dd@idAg dBdddCœfd%g i fdDœdEdFdGœd%g ddd&œfd*g dHddIœfdg ddifdJg d-ddKœfdg dLdMdœfdg ddNd9œfdg ddd1œfdOœdPdQdGœd%g ddd&œfd*g dHddIœfdg ddifdJg i fdg ddNd9œfdRœi ddSdTdUœ“ddg dVdif“dWd%g dVdif“d0d%g dVdif“dXd*g dHddIœf“d2dg ddif“d5dg dVdif“d8dg d.dddYœf“dZdg dVdif“d[dg d+d?if“d\d]g dVdif“d^dg ddd_œf“d`dg ddad9œf“dbdg dVdif“dcd%g dddif“ded!g dfddgœf“dhdidUœdg ddNd9œfdg ddifd%g dddjœfdkœdlœZdmgZ	dnS )oÚ	Migrationc                 C   sF   t tj }|j | ¡ ¡}d|vr|  ¡  d|vr|  ¡  |  ¡  d S )NÚcelery_taskmetaÚcelery_tasksetmeta)	r   r   Údb_aliasÚintrospectionÚget_table_listÚcursorÚcreate_celery_taskmetaÚcreate_celery_tasksetmetaÚapply_current_migration)ÚselfÚormÚconnÚ
table_list© r   ú\/var/www/html/env/lib/python3.10/site-packages/djcelery/south_migrations/0002_v25_changes.pyÚforwards
   s   
zMigration.forwardsc                 C   s”   t  dd|  d¡dd�fd|  d¡ddd	�fd
|  d¡ddd�fd|  d¡d dd�fd|  d¡ddd�fd|  d¡ddd�ff¡ t  ddg¡ d S )Nr   Úidú!django.db.models.fields.AutoFieldT©Úprimary_keyÚtask_idú!django.db.models.fields.CharFieldéÿ   ©ÚuniqueÚ
max_lengthÚstatusÚPENDINGé2   ©Údefaultr    Úresultú'djcelery.picklefield.PickledObjectField©r%   ÚnullÚ	date_doneú%django.db.models.fields.DateTimeField©Úauto_nowÚblankÚ	tracebackú!django.db.models.fields.TextField©r)   r.   ÚdjceleryÚTaskMeta©r   Úcreate_tableÚgfÚsend_create_signal©r   r   r   r   r      s   úz Migration.create_celery_taskmetac                 C   sf   t  dd|  d¡dd�fd|  d¡ddd	�fd
|  d¡ƒ fd|  d¡ddd�ff¡ t  ddg¡ d S )Nr   r   r   Tr   Ú
taskset_idr   r   r   r&   r'   r*   r+   r,   r2   ÚTaskSetMetar4   r8   r   r   r   r      s   üz#Migration.create_celery_tasksetmetac                 C   sd   t jdd|  d¡ddd�dd� t jd	d
|  d¡ddd�dd� t jdd
|  d¡ddd�dd� d S )NÚdjcelery_periodictaskÚdescriptionr0   Ú T©r%   r.   F)Úkeep_defaultr   Úhiddenú$django.db.models.fields.BooleanField©r%   Údb_indexr   )r   Ú
add_columnr6   r8   r   r   r   r   )   s     $z!Migration.apply_current_migrationc                 C   s(   t  dd¡ t  dd¡ t  dd¡ d S )Nr;   r<   r   r@   r   )r   Údelete_column)r   r   r   r   r   Ú	backwards4   s   zMigration.backwardsÚobject_nameÚCrontabScheduler   z'*'Ú64r$   r   r   ÚTrue)ÚMetaÚday_of_weekÚhourr   ÚminuteÚIntervalSchedulez$django.db.models.fields.IntegerFieldr    Ú24)rK   Úeveryr   ÚperiodrK   ÚPeriodicTaskÚargsr0   z'[]'r>   Úcrontabz*django.db.models.fields.related.ForeignKeyzorm['djcelery.CrontabSchedule'])Útor)   r.   Údate_changedr+   r,   r<   r.   ÚenabledrA   r%   ÚexchangeÚNoneÚ200)r%   r    r)   r.   Úexpiresr1   r   Úintervalz orm['djcelery.IntervalSchedule']Úkwargsz'{}'Úlast_run_atÚnamer   ÚqueueÚrouting_keyÚtaskÚtotal_run_countz,django.db.models.fields.PositiveIntegerFieldÚ0ÚPeriodicTasksz)django.db.models.fields.SmallIntegerFieldÚ1)r%   r   r   )rK   ÚidentÚlast_updater3   z'celery_taskmeta')rG   Údb_tableÚFalserB   r'   r(   z	'PENDING'Ú50Ú255)rK   r*   r@   r   r&   r!   r   r/   r:   z'celery_tasksetmeta')rK   r*   r@   r   r&   r9   z['-tstamp']Ú	TaskState)ÚorderingrG   r)   Úetar@   )r    r)   rC   r&   ÚretriesÚruntimez"django.db.models.fields.FloatFieldÚstate)r    rC   r   Ú36r/   ÚtstamprC   Úworkerzorm['djcelery.WorkerState'])rV   r)   z['-last_heartbeat']ÚWorkerState)r)   rC   )rK   Úhostnamer   Úlast_heartbeat)zdjcelery.crontabschedulezdjcelery.intervalschedulezdjcelery.periodictaskzdjcelery.periodictaskszdjcelery.taskmetazdjcelery.tasksetmetazdjcelery.taskstatezdjcelery.workerstater2   N)
Ú__name__Ú
__module__Ú__qualname__r   r   r   r   rF   ÚmodelsÚcomplete_appsr   r   r   r   r      sà    	
ûüÿþýüûúùø	÷
öõôóòñðïýøú
ÿþýüûúùø	÷
öõôóòñðü¶
Rr   N)	Ú
__future__r   Úsouth.dbr   Úsouth.v2r   Ú	django.dbr   r   r   r   r   r   Ú<module>   s
   