]jA(ddlZddlmZddlZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZd d lmZmZej&eZd Zdd Zd ZdZddZddZddZdZdZdZdZ y)Nwraps)flag_set)start_job_async_or_sync) load_func)settings)Q)QuerySet)Webhook WebhookActionc tj|}|r|jdr tdtj j t|t|tdzztdztdttj j || jd d  zzjS) zReturn all active webhooks for organization or project by action. If project is None - function return only organization hooks else project is not None - function return project and organization hooks Organization hooks are global hooks. zorganization-onlyz9There is no project webhooks for organization-only action) organization)projectNT) is_active)send_for_all_actions)webhook__organizationaction webhook_id)flatid__in) r ACTIONSget ValueErrorr objectsfilterr values_listdistinct)rrr action_metas E/root/env/lib/python3.12/site-packages/label_studio/webhooks/utils.pyget_active_webhooksr"s ''/K;??#67TUU ?? ! ! |$ W $ / 1 d   4 ($,,33,_e3frr ts   hj cpd|i}|jr|r|j| tjd|j|t j |j|j|tjS#t j$r!}tj|dYd}~yd}~wwxYw)zRRun one webhook for action. This function must not raise any exceptions. rzRun webhook %s for action %s)headersjsontimeoutT)exc_infoN) send_payloadupdateloggingdebugidrequestsposturlr%rWEBHOOK_TIMEOUTRequestExceptionerror)webhookrpayloaddataexcs r!run_webhook_syncr8+s & D G  4gjj&I}} KKOO,,    $ $ cD)sABB5B00B5ct|||}|rR|rP|jdjr0ttj d|j |d<|D]}t|||y)z1 Run all active webhooks for the action. Tr)rinstanceN)r"rexistsrrWEBHOOK_SERIALIZERSr6r8)rrrr5webhookswhs r!emit_webhooks_syncrABsp#<&AH7xDAHHJOYx'C'CI'NOY`aff .VW-.r#ci}|r|jdjr|jd}|r|||dj||d<|r2|r0t t j d|j|d<|rId |vrE|d jD]/\}}|dt||d |dj||<1|D]} t| ||y ) a!Process a single batch of instances for webhooks. Args: webhooks: Active webhooks to send project: Project instance (optional) action: Action name batch: Batch of instances to process action_meta: Action metadata from WebhookAction.ACTIONS Tr: serializermany)r<rDkeyrr;z nested-fieldsfieldN) rr=rr6rrr>itemsget_nested_fieldr8) r?rrbatchr r5serializer_classrEvaluer@s r!_process_webhook_batchrLMsG d3::<&??<8 *:EP[\bPc*d*i*iGK& ' w!S8+G+G +R!S]d!e!j!jGI  +5)/:@@B  U2u\2-eU7^D5QW= $   .VW-.r#c t|||}|jsytj|}|rBt |t r2t |dt r|djj|}t |t tf}|xr td}|r)tj}t |tr|j} tjd| d|t!d| |D]I} || | |z} tjd| |zd zd | jd t#|||| |Kyt%|} tjd| d|t!dt%||D]D} || | |z} tjd| |zd zd t%| d t#|||| |Fyt#|||||y) zRun all active webhooks for the action using instances as payload. Be sure WebhookAction.ACTIONS contains all required fields. Nrmodelr@fflag_fix_back_plt_843_webhook_memory_improvement_12082025_shortzProcessing webhook for z instances in batches of zProcessing batch r z with z instances)r"r=r r isinstancelistintrrr rrWEBHOOK_BATCH_SIZEcountloggerr,rangerLlen) rrrr<r?r is_batch_collection use_batching batch_size total_countirIs r!emit_webhooks_for_instance_syncr]is #<&AH ?? ''/KJx.:hqk33Ow'//66h6G%Xh/?@&w84v+wL00 h )"..*K LL2;-?XYcXde f1k:6 V Q^4 0j11D0EVEKKM?Zdef&x&%U V h-K LL2;-?XYcXde f1c(mZ8 V Q^4 0j11D0EVCPUJ.decorator..wrapsD';D;F;H'//7Kv&D"7+33778==;L;LT;R7SH$:G+-*8[5QR & 00   Or#rrurvrs` r! decoratorzapi_webhook..decorators t   & r#rrxs` r! api_webhookr{s. r#cfd}|S)aDecorator emit webhooks for APIView delete method. The decorator expects authorized request and use get_object() method before delete. Example: ``` @extend_schema(tags=['Annotations']) @api_webhook_for_delete(WebhookAction.ANNOTATIONS_DELETED) def delete(self, request, *args, **kwargs): return super(AnnotationAPI, self).delete(request, *args, **kwargs) ``` c2tfd}|S)Nc|j}tj }|d}d}d|vrt||d}d|ji}|r|g} ||g|i|} t |j j| || S)NrDrmr-) get_objectr rrHpkrgrnro) rprqrrrsr<r rDrobjrtrrus r!rvz7api_webhook_for_delete..decorator..wraps(H'//7Kv&DG+-*8[5QR%CeD';D;F;H &w||'G'GRXZ] ^Or#rrws` r!rxz)api_webhook_for_delete..decorators t   " r#ryrzs` r!api_webhook_for_deleters* r#c|dk(r|S|jd}|D]8}t|tr|Dcgc]}t||}}-t||}:|Scc}w)z Get nested field from list of objects or single instance :param value: Single instance or list to look up field :param field: Field to lookup :return: List or single instance of looked up field __self____)splitrPrQgetattr)rKrFfieldsfldvs r!rHrHsi  [[ F( eT ".34WQ_4E4E3'E ( L5sA)N)!r+ functoolsrr.core.feature_flagsr core.redisrcore.utils.commonr django.confrdjango.db.modelsr django.db.models.queryr modelsr r getLogger__name__rUr"r8rArLr]rcrgrir{rrHryr#r!rsr'.' +*   8 $4...8)QX3&Q& C%P$Nr#