]j dZddlZddlmZddlmZddlmZmZddl m Z ddl m Z ddl mZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddl m!Z!ddl"m#Z#m$Z$m%Z%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,m-Z-ddl.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4ddl5m6Z6ddl7m8Z8m9Z9m:Z:m;Z;ddlZ>m?Z?m@Z@mAZAmBZBmCZCddlDmEZEmFZFmGZGmHZHmIZIddlJmKZKddlLmMZMmNZNmOZOejeQZRede r+e&dgd d!d"eBid#e%d$eHe#d%eCd"&g'id(d)d*gd+,nd-.ed/e re&dgd0d1e$d2e!jd3d45e$d6e!jd3d75e$d8e!jd3d95e$d:e!jd;de$d?e!jd3d@5e$dAe!jd3dB5e$d3e!jd3dC5gdDe%dEdFdGdHdIdFdJdKdLdMdJdNdMdJdOdMdJdPdQRid(dSdTdUdVd*gdWXndY.GdZd[eZed/e&dgd\d]e$d^e!jd_d`5gddDe%daee#d%e?d"&g'id(d/d*gd+b.edce&dgdddee$d^e!jd_d`5gd"eBidDe%dfeHe#d%eCd"&g'id(dgd*gd+b.edhe&dgdidje$d^e!jd_d`5gdd(dhd*gd+k.Gdldme,jZWed/e&dgdndodDe%dpe#d%dqdrdsdtdudvdwdxidyd"&gzid{d|gi}.Gd~de,jZYed/e&dgddddDe%deFe#d%e>d"&g'idd/d*gd+,.edce&dgddd"e=idDe%deFe#d%e>d"&g'iddgd*gd+,.edhe&dgdddddhd*gd+.Gdde,jZZed/e&dgdde$d^e!jd_d`5gddDe%deFde#d%e>gd"&g'iddSd*gd+b.ede&dgdde$d^e!jd_d`5gd"e=id#e%deFe#d%e>d"&g'idd)d*gd+b.Gddee,jZ\e&dGdde,jZ]e&dGdde,jZ^edSe&dgdde$de!jd3d5e$d6e!jd3d5gddDe%deGde#d%eAgd"&g'iddSd*gd+b.ed)e&dgddd"e@id#e%deGe#d%eAd"&g'idd)d*gd+,.ede&dgdde$d^e!jd_d5gddDe%deGe#d%eAd"&g'idd/d*gd+b.edge&dgdde$d^e!jd_d5gd"e@idDe%deGe#d%eAd"&g'id{d|gib.ede&dgdde$d^e!jd_d5gd"e@idDe%deGe#d%eAd"&g'iddgd*gd+b.ede&dgdde$d^e!jd_d5gdddhd*gd+k.Gdde-jZ`ed/e&d.ede&dgddd{d|gi.Gdde,jZay)zThis file and its contents are licensed under the Apache License 2.0. Please see the included NOTICE for copyright information and LICENSE for a copy of the license.N)flag_set)GetParentObjectMixin)ViewClassPermissionall_permissions) is_community)bool_from_request) TaskListAPI)evaluate_predictions) PrepareParams)DataManagerTaskSerializer) transaction)Q)timezone)method_decorator)DjangoFilterBackend) OpenApiTypes)OpenApiExampleOpenApiParameterOpenApiResponse extend_schema)fill_history_annotation)Project)genericsviewsets)PermissionDeniedValidationError) FormParser JSONParserMultiPartParser)Response) AnnotationAnnotationDraft PredictionTask)annotation_request_schemaannotation_response_exampledm_task_response_exampleprediction_request_schemaprediction_response_exampletask_request_schematask_response_example)AnnotationDraftSerializerAnnotationSerializerPredictionSerializerTaskSerializerTaskSimpleSerializer) WebhookAction) api_webhookapi_webhook_for_deleteemit_webhooks_for_instancepostTasksz Create taskz+Create a new labeling task in Label Studio.zapplication/json201z Created taskresponse)namevalue media_type) descriptionr8examplestaskscreatepublic)x-fern-sdk-group-namex-fern-sdk-method-namex-fern-audiences)tagssummaryr<request responses extensionsc|SNfs @/root/env/lib/python3.12/site-packages/label_studio/tasks/api.pyrON1)r9 decoratorgetzGet tasks listzq Retrieve a list of tasks with pagination for a specific view or project, by using filters and ordering. viewqueryzView ID)r9typelocationr<projectz Project ID resolve_uriz*Resolve task data URIs using Cloud Storagefieldsall task_onlyzOSet to "all" if you want to include annotations and predictions in the response)r9rVenumdefaultrWr<reviewzGet tasks for reviewincludez/Specify which fields to include in the responseaAdditional query to filter tasks. It must be JSON encoded string of dict containing one of the following parameters: `{"filters": ..., "selectedItems": ..., "ordering": ...}`. Check [Data Manager > Create View > see `data` field](#tag/Data-Manager/operation/api_dm_views_create) for more details about filters, selectedItems and ordering. * **filters**: dict with `"conjunction"` string (`"or"` or `"and"`) and list of filters in `"items"` array. Each filter is a dictionary with keys: `"filter"`, `"operator"`, `"type"`, `"value"`. [Read more about available filters](https://labelstud.io/sdk/data_manager.html)
Example: `{"conjunction": "or", "items": [{"filter": "filter:tasks:completed_at", "operator": "greater", "type": "Datetime", "value": "2021-01-01T00:00:00.000Z"}]}` * **selectedItems**: dictionary with keys: `"all"`, `"included"`, `"excluded"`. If "all" is `false`, `"included"` must be used. If "all" is `true`, `"excluded"` must be used.
Examples: `{"all": false, "included": [1, 2, 3]}` or `{"all": true, "excluded": [4, 5]}` * **ordering**: list of fields to order by. Currently, ordering is supported by only one parameter.
Example: `["completed_at"]`200z Tasks listobjectz List of tasksarrayz Task object)r<rV)r<rVitemszTotal number of tasksintegerzTotal number of annotationszTotal number of predictions)r>totaltotal_annotationstotal_predictions)rV properties)r<r8listz $request.pagez$response.tasks)offsetresults)rArBzx-fern-paginationrC)rDrEr< parametersrGrHc|SrJrKrLs rNrOrOrPrQczeZdZeZeejejZ e gZ dgZ fdZ fdZdZxZS)r GETPOSTrXct||}|j|jjj SNproject__organization)superfilter_querysetfilterrFuseractive_organization)selfqueryset __class__s rNrxzTaskListAPI.filter_querysets37*84T\\5F5F5Z5Z[[rQct|}|jjj d}|rt j t||d<|S)NrXpk)rwget_serializer_contextrFdatarSrget_object_or_404r)r|context project_idr~s rNrz"TaskListAPI.get_serializer_contextsI'02\\&&**95 !)!;!;G !SGI rQc|jjjd}tjt |}|j |}t|jjj|tj|gy)NrXr)rX) rFrrSrrrsaver4rzr{r1 TASKS_CREATED)r| serializerrrXinstances rNperform_createzTaskListAPI.perform_createsi\\&&**95 ,,WD??7?3" LL   1 17M/resolve/?fileuri=...). This is useful for: - resolve_uri=True (default): URLs are proxied through Label Studio for security - resolve_uri=False: Original storage URLs are preserved, useful for debugging or when users need to see the actual source paths in task preview )draftsrrF+fflag_fix_all_fit_720_lazy_load_annotationsrzannotations_stubrYTrrr)rYrrrrrF)rrzrrq)r|rFrZrs rNget_retrieve_serializer_contextz'TaskAPI.get_retrieve_serializer_context2so:! A U0>PRWX -W[[-N(F2(F2&( 0   rQc|j|}|jjx|d<}|js |jrO|jj j s+t|jg|j|_|jdrgndg}|j|jd||}|j}t|S)NrXrzannotations.completed_byF)manyrexpand) rrrX"evaluate_predictions_automaticallyshow_collab_predictionsrexistsr rrSget_serializer_classrr )r|rFrrrXrrrs rNrSz TaskAPI.getKs66w?'+yy'8'88 W  6 6':Y:Y))''..0 $)) -)DI {{#56=WO>O>S>ST]>^llooG}} MM & & ,WH^b^j^jk ou   rQc|jjd}tjtj j |jjjjd|}|j|j||j|j}tj||S)z Override to check permissions on a lightweight task first. This avoids executing the expensive PreparedTaskManager query when the user doesn't have permission to access the task. rrurXr)rrSrrr$objectsryrFrzr{select_relatedcheck_object_permissionsrxr)r|r lean_taskr}s rNrzTaskAPI.get_objectws++//$'.. LL  dll6G6G6[6[  \ k klu v  %%dllI>''(9(9(;<))(w??rQcL|jjdk(rtStS)Nrq)rFmethodr r0rs rNrzTaskAPI.get_serializer_classs" <<  % ', ,( 'rQc2tt| |g|i|SrJ)rwrrrs rNrz TaskAPI.patchsWd)'CDCFCCrQc2tt| |g|i|SrJ)rwrrrs rNrzTaskAPI.deletesWd*7DTDVDDrQTexcludec2tt| |g|i|SrJ)rwrputrs rNrz TaskAPI.putsWd'A$A&AArQ)rrrrrrparser_classesrrr tasks_change tasks_deleterrrrrSrrrrrr3r1 TASKS_DELETEDrrrrrs@rNrrsP!*o>N-  & &  ( (**++ &   2(> *@*(DM778E9E4 B!BrQrzGet task label distributionzGet aggregated label distribution across all annotations for a task. Returns counts of each label value grouped by control tag. This is an efficient endpoint that avoids N+1 queries.zLabel distribution datadlabelrectanglelabels-)CarPersonDog)rVlabelsrg distributions)r<r=rCinternal)rDrEr<rGrHcpeZdZdZeej ZejjZ dZ y)TaskAgreementAPIa Efficient endpoint for getting label distribution without fetching all annotations. This endpoint aggregates annotation results at the database level to avoid N+1 queries. It returns pre-computed label counts for the Distribution row in the Summary view. )rqc@ td|js td tjj |}|jj|js td tjj|d jd d }t|}i fd}|D] }|| tjj|jd d }|D]}t|t s|| j#D]>\} } | dr1t%| dt| dz | d<t| d| d<| d=@t| dS#tj $rtddidcYSwxYw)NrrzFeature not enabledrerrorzTask not foundi)statusz,You do not have permission to view this taskF)r was_cancelledresultT)flatc|rt|tsy|D]1}t|ts|jdd}|jdd}|jdi}|vr |igd|<|j drS|j|g}t|ts|D]*}||dvr d|d|<|d|xxd z cc<,|d k(rT|jd g}t|ts|D]*}||dvr d|d|<|d|xxd z cc<,|d k(r.|jd } | /|d j | H|d k(r.|jd } | b|d j | {|dk(rn|jdg} t| ts| D]C} t| ts| s| d} | |dvr d|d| <|d| xxd z cc<E|dk(s|jd}|s ||dvr d|d|<|d|xxd z cc<4y)zKMerge a single result (list of labeling items) into distributions in place.N from_namerVr:)rVrvaluesrrchoicesratingrnumbertaxonomypairwiser) isinstancerjdictrSendswithappend)ritemr result_typer:rrrchoicerrrrleafrrs rNmerge_result_into_distributionsz=TaskAgreementAPI.get..merge_result_into_distributionssFD!97 J!$- HH["5 "hhvr2 "-M1 +"$"$0M), ''1"YY{B7F!&$/%+KE$M),DX,NNLM i 8 B5 I))4X>uEJEK !I-#ii 26G!'40&-LF%]9-Eh-OOMN i 8 B6 J))4X>vF!KFL !H,"YYx0F)%i0:AA&I H,"YYx0F)%i0:AA&I J.$yyR8H!(D1$,ND)$5$'+Bx#'}Y/G/Q#QOPM)$xH%i0:8DIDo7 JrQrraveragecountr)rrzrr$rrS DoesNotExistr rXhas_permissionr!ry values_listlenr#r rjrdsum) r|rFrrrrgrrrrdistrs @rNrSzTaskAgreementAPI.getsEGLLY"#89 9 E<<##r#*D ||**7<<8"#QR R!((//0  +hT+ *   , ; J|" 4F +F 3 4 !((//T/:FFxVZF[ ! 8F&$'/7 8 -224 OItH~"%d8n"5DN8K"KY #DN 3W X  %6!.   C   EW&67D D Es E88"FFN) rrr__doc__rrrrr$rr[r}rSrKrQrNrrs3D./2L2LM||!Hm rQr AnnotationszGet annotation by its IDzIRetrieve a specific annotation for a task using the annotation result ID.zRetrieved annotationrzUpdate annotationz,Update existing attributes on an annotation.zUpdated annotationzDelete annotationz2Delete an annotation. This action can't be undone!)rDrEr<rFrHceZdZeeefZeejejejejZ e Zej j#ZdZfdZfdZeej0edfdZeej0fdZeej:fd ZxZS) AnnotationAPIrc$|jyrJ)r)r| annotations rNperform_destroyzAnnotationAPI.perform_destroysrQc|j}tjj|jj |j |j}|jjjdr|j|j|j|jtt||g|i|}|j|jdg|S)Nr) updated_by ground_truth annotation_id updated_at) update_fields)rr!rryrrrzrrFrrSensure_unique_groundtruthupdate_is_labeledrrwr)r|rFrrr rrr~s rNrzAnnotationAPI.updates__& !!Z]]!3::gll:S <<    0  * * * G   }d27LTLVL    / rQc2tt| |g|i|SrJ)rwrrSrs rNrSzAnnotationAPI.gets]D-gGGGGrQTrc2tt| |g|i|SrJ)rwrrrs rNrzAnnotationAPI.puts!]D-gGGGGrQc2tt| |g|i|SrJ)rwrrrs rNrzAnnotationAPI.patchs]D/I$I&IIrQc2tt| |g|i|SrJ)rwrrrs rNrzAnnotationAPI.deletes]D0J4J6JJrQ) rrrrrrrrrannotations_viewannotations_changeannotations_deleterr-rr!rr[r}r!rrSr2r1ANNOTATION_UPDATEDrrrr3ANNOTATIONS_DELETEDrrrs@rNrr=s~!*o>N-  , ,  . .0011 ,!!%%'H$H1124 H!3H112J3JM==>K?KrQrzGet all task annotationsz List all annotations for a task.r!T)rzCreate annotationa Add annotations to a task like an annotator does. The content of the result field depends on your labeling configuration. For example, send the following data as part of your POST request to send an empty annotation with the ID of the user who completed the task: ```json { "result": {}, "was_cancelled": true, "ground_truth": true, "lead_time": 0, "task": 0 "completed_by": 123 } ``` zCreated annotationceZdZeeefZeejejZ e jjZeZfdZeej*fdZdZdZdZxZS)AnnotationsListAPIrpc2tt| |g|i|SrJ)rwr6rSrs rNrSzAnnotationsListAPI.gets '27LTLVLLrQc2tt| |g|i|SrJ)rwr6r5rs rNr5zAnnotationsListAPI.posts '3GMdMfMMrQcPtjtjj |j j |jjdd}tjjt|tdzjdS)NrrrrF)r) rrr$rfor_userrFrzrrSr!ryrorder_by)r|rs rNrzAnnotationsListAPI.get_querysetst))$,,*?*? @Q@Q*RW[WbWbWfWfgkmnWop!!((8N)NOXXY]^^rQc tjj|}|jy#tj$rYywxYw)Nr#)r"rrSrr)r|draft_idr'drafts rN delete_draftzAnnotationsListAPI.delete_draftsC #++//8/r s rNrz!AnnotationsListAPI.perform_createsW!!||  .dll.>.>QVW!\\..22?EJ'=+= t224!8-K"LM M##''1!%T!2$//R   #++22DLLLfLf2gJ  "'--/ !5j!A!F!F uT\\%6%6$77[\`[abc!#   ^4P Q dll.. .*;DLLN-  , ,  / /ll&&(O+M112N3N_ ErQr6rceZdZeeefZeZe e je jZ ejj!ZdZdZy)AnnotationDraftListAPIrpcD|jd}|j|S)Nr)r)rry)r|r}rs rNrxz&AnnotationDraftListAPI.filter_querysetds!++d#w//rQc*|jd}|jjd}|jj}tj d|d|d||j |jd||jjy)Nrr'zUser z# is going to create draft for task=z , annotation=)rr'rz)rrSrFrzrJrKr)r|rrr'rzs rNrz%AnnotationDraftListAPI.perform_createhs{++d# 8 ||   uTF"EgYm\i[jkl D 1UYUaUaUfUfgrQN)rrrrrrrr,rrrr0rWrr"rr[r}rxrrKrQrNr[r[ZsR /:>N0-  , ,  / /&&**,H0hrQr[ceZdZeeefZeZe jjZ e ejej ej ej"Zy)AnnotationDraftAPIrN)rrrrrrrr,rr"rr[r}rrr0r1r2rrKrQrNr_r_psW /:>N0&&**,H-  , ,  . .0011 rQr_ PredictionszList predictionsz#List all predictions and their IDs.rzFilter predictions by task IDz Filter predictions by project IDzPredictions listrzCreate predictionz(Create a prediction for a specific task.zCreated predictionretrievezGet prediction detailsz2Get details about a specific prediction by its ID.z Prediction IDzPrediction detailszPut predictionz+Overwrite prediction data by prediction ID.zUpdated predictionpartial_updatezUpdate predictionz(Update prediction data by prediction ID.destroyzDelete predictionz%Delete a prediction by prediction ID.c<eZdZeZej ZegZ gdZ dZ y) PredictionAPI)r task__projectrXc~tjj|jjj Srt)r#rryrFrzr{rs rNrzPredictionAPI.get_queryset"s,!!((t||?P?P?d?d(eerQN) rrrr.rrpredictions_anyrrrrrrKrQrNrere}s+@,)99*+O;frQrezConvert annotation to draft)rDrEr<rHcreZdZeej ZejjZ dZ dZ y)AnnotationConvertAPI)rrcyrJrK)r|r r>s rNprocess_intermediate_statez/AnnotationConvertAPI.process_intermediate_state6s rQc,|j}|jj}|j}|j}t j 5t jj|j|j|jd|j}|j|||jdddt||t j"|gt%j&} t)d| S#1swYIxYw)N)r lead_timerr rz)r)rr)rrX organizationrr atomicr"rr?rrnrrzrlrr4r1r4r,rr ) r|rFrrr rprXrr>rs rNr5zAnnotationConvertAPI.post9s__& !))66 $$ ]]    ! #++22!(($..__\\ 3E  + +J >      #<-:[:[^`]ab(%8==s.. s A/D  DN) rrrrrr1rr!rr[r}rlr5rKrQrNrjrj&s3.?3U3UV!!%%'H /rQrj)brloggingcore.feature_flagsr core.mixinsrcore.permissionsrrcore.utils.commonrcore.utils.paramsrdata_manager.apir DMTaskListAPIdata_manager.functionsr data_manager.modelsr data_manager.serializersr django.dbr django.db.modelsr django.utilsrdjango.utils.decoratorsrdjango_filters.rest_frameworkrdrf_spectacular.typesrdrf_spectacular.utilsrrrr!projects.functions.stream_historyrprojects.modelsrrest_frameworkrrrest_framework.exceptionsrrrest_framework.parsersrrrrest_framework.responser tasks.modelsr!r"r#r$tasks.openapi_schemar%r&r'r(r)r*r+tasks.serializersr,r-r.r/r0webhooks.modelsr1webhooks.utilsr2r3r4 getLoggerrrJINTBOOLSTRRetrieveUpdateDestroyAPIViewrRetrieveAPIViewrrListCreateAPIViewr6r[r_ ModelViewSetrerjrKrQrNrs l',A*/97->!!4=.bbE#-GJJ,FF*   8 $ *~)YA  3  ?*'(j@Ubtuv &-&.!)  * /2 |~{Y  &|/?/?'_h i ),2B2BWbn o "!&& H   !%%[)# m   !&& 2   !%% M   !%%  A  ;. ` ?($,;$+/<(0&",C$-" ,I$-. ,I$-.## >&-&,),""*  g\| AaD - Ea3v : Y  $\-=-=\e f  ?"2" :R_qr &-&+!)  '8 YI $\-=-=\e f   3  ?*'(j@Ubtuv &-&.!)  #4 YR $\-=-=\e f %,&.!)   "HBh33HB#59NHBV Y-A ?5"'14 ',=68Br.R*".$6  *   5 Bx x//x C Bx v _*_ ?2-" :Ubtu &3&+!)  . _#B  9  ?0-" :Ubtu &3&.!)  !2 _#H%2&.!)   /KH99/K 3/|/Kd _*6 $\-=-=\e f  ?(-48" ;V:Wdvw &3&,!)  #4 _# " $\-=-=\e f   9  ?0-" :Ubtu &3&.!)  E'*Ve-x/I/IeW*5JePthX77hh*t >>   _"9 !%% ;   !%% >     ?.-48" ;V:Wdvw &3&,!)  9!$J _#>  9  ?0-" :Ubtu &3&.!)  !2 _(H $\-=-=\k l  ?0-" :Ubtu &3&+!)  #4 _ A $\-=-=\k l   9  ?0-" :Ubtu    '4 _#> $\-=-=\k l   9  ?0-" :Ubtu &3&.!)  '8 _#; $\-=-=\k l %2&.!)   "fH))f#9553K$~fu d(CD _-1    /833/ E/rQ