
    .$h)                     6    d dl mZmZ d dlmZ  G d de      Zy)    )BaseCommandCommandError)task_send_inactive_ads_to_cloudc                       e Zd ZdZd Zd Zy)Commandu   Wyślij nieaktywne ogłoszenia do chmury (endpoint receive-inactive).
Domyślnie uruchamia task Celery (async). Możesz użyć --eager, aby wykonać od razu (sync).c                    |j                  dddgdd       |j                  dt        d d       |j                  d	t        d d
       |j                  ddd       |j                  ddd       |j                  dt        dd       y )Nz--modebatchpipelineuL   batch = jedna paczka i koniec; pipeline = uruchamia się w pętli z lockiem.)choicesdefaulthelpz--limituJ   Rozmiar paczki (domyślnie wartość z settings: ADS_INACTIVE_BATCH_SIZE).)typer   r   z	--timeoutuI   Timeout requestu (domyślnie wartość z settings: ADS_INACTIVE_TIMEOUT).z--eager
store_truez9Uruchom synchronicznie w tym samym procesie (bez Celery).)actionr   z--waitz8(Tylko async) Poczekaj na wynik taska i wypisz rezultat.z--queue-timeoutiX  uD   Ile maksymalnie czekać (sek) na wynik przy --wait (domyślnie 600).)add_argumentint)selfparsers     C/var/www/extractly/houslyspace/management/commands/sync_inactive.pyadd_argumentszCommand.add_arguments   s    j)_	 	 	
 	]	 	 	
 	\	 	 	
 	L 	 	

 	K 	 	

 	W	 	 	
    c                     |d   }|d   }|d   }|d   }|d   }|d   }d|i}	|t        |      |	d<   |t        |      |	d<   |r| j                  j                  | j                  j	                  d|	              t        j                  |	      }
	 |
j                  d	
      }| j                  j                  | j                  j                  d|              y | j                  j                  d|	        t        j                  |	      }| j                  j                  | j                  j                  d|j                                |rk| j                  j                  d| d       	 |j                  |d	      }| j                  j                  | j                  j                  d|              y y # t        $ r}t        d|       |d }~ww xY w# t        $ r}t        d|       |d }~ww xY w)Nmodelimittimeouteagerwaitqueue_timeoutz1[sync_inactive] Running EAGER (sync) with kwargs=)kwargsT)	propagatezEAGER run failed: z[sync_inactive] Done (eager): z2[sync_inactive] Enqueuing Celery task with kwargs=z"[sync_inactive] Task enqueued: id=z*[sync_inactive] Waiting for result (up to u   s)…)r   r    zWaiting failed: z[sync_inactive] Result: )r   stdoutwritestyleWARNINGr   applyget	Exceptionr   SUCCESSapply_asyncid)r   argsoptionsr   r   r   r   r   r   r   resresulte	async_ress                 r   handlezCommand.handle/   s
   v )$ v0$!%jF7O #GF9KKdjj00CF8L  277vFCD40 KKdjj003QRXQY1Z[\ 	NvhWX3??vN	$**,,/QR[R^R^Q_-`abKK J=/Y^_`B"}M KKdjj003KF81TUV   D"%7s#;<!CD  B"%5aS#9:ABs0   G  4G   	G	GG 	G=)G88G=N)__name__
__module____qualname__r   r   r1    r   r   r   r      s    	i 	
"
H&Wr   r   N)django.core.management.baser   r   houslyspace.tasksr   r   r5   r   r   <module>r8      s    A =PWk PWr   