trust_api.services.task_handlers

Task handlers for processing tasks received from the central hub via polling.

Each handler processes a specific task type and returns a result dict.

Attributes

`DATA_ACCESS_API_URL`
`CENTRAL_HUB_API_URL`
`IMAGING_API_URL`
`TRUST_API_KEY`
`TRUST_API_KEY_HEADER`
`TRUST_INTERNAL_SERVICE_KEY`
`TRUST_INTERNAL_SERVICE_KEY_HEADER`
`TASK_COHORT_QUERY`
`TASK_CREATE_IMAGING`
`TASK_DELETE_IMAGING`
`TASK_GET_IMAGING_STATUS`
`TASK_REIMPORT_STUDIES`
`TASK_UPDATE_USER_PROFILE`
`TASK_HANDLERS`

`_trust_internal_headers`(→ dict[str, str])	Return the auth header sent on every trust-internal call.
`handle_cohort_query`(→ dict[str, Any])	Process a cohort query task.
`handle_create_imaging`(→ dict[str, Any])	Process an imaging project creation task.
`handle_delete_imaging`(→ dict[str, Any])	Process an imaging project deletion task.
`handle_get_imaging_status`(→ dict[str, Any])	Process an imaging status retrieval task.
`handle_reimport_studies`(→ dict[str, Any])	Process a reimport studies task.
`handle_update_user_profile`(→ dict[str, Any])	Process a user profile update task.

trust_api.services.task_handlers.TRUST_INTERNAL_SERVICE_KEY_HEADER = 'X-Trust-Internal-Service-Key'

trust_api.services.task_handlers._trust_internal_headers() → dict[str, str]

Return the auth header sent on every trust-internal call.

Used for imaging-api and data-access-api requests; both validate the same per-trust TRUST_INTERNAL_SERVICE_KEY against their stored hash.

Returns:: Single-entry dict mapping the configured header name to the trust-internal service key.
Return type:: dict[str, str]

trust_api.services.task_handlers.TASK_GET_IMAGING_STATUS = 'get_imaging_status'

trust_api.services.task_handlers.TASK_REIMPORT_STUDIES = 'reimport_studies'

trust_api.services.task_handlers.TASK_UPDATE_USER_PROFILE = 'update_user_profile'

async trust_api.services.task_handlers.handle_cohort_query(payload: dict[str, Any]) → dict[str, Any]

Process a cohort query task.

Calls the local data-access-api, then pushes results back to the central hub.

Parameters:: payload – Task payload containing query details (query, query_name, encrypted_project_id, etc.)
Returns:: dict with success status and any error details.

async trust_api.services.task_handlers.handle_create_imaging(payload: dict[str, Any]) → dict[str, Any]

Process an imaging project creation task.

Calls the local imaging-api to create the project.

async trust_api.services.task_handlers.handle_delete_imaging(payload: dict[str, Any]) → dict[str, Any]

Process an imaging project deletion task.

async trust_api.services.task_handlers.handle_get_imaging_status(payload: dict[str, Any]) → dict[str, Any]

Process an imaging status retrieval task.

Gets the import status from the local imaging-api and reports back to the hub.

Parameters:: payload – Task payload containing imaging_project_id and encoded_query.
Returns:: dict with success status and imaging status result.

async trust_api.services.task_handlers.handle_reimport_studies(payload: dict[str, Any]) → dict[str, Any]

Process a reimport studies task.

Parameters:: payload – Task payload containing imaging_project_id and encoded_query.
Returns:: dict with success status.

async trust_api.services.task_handlers.handle_update_user_profile(payload: dict[str, Any]) → dict[str, Any]

Process a user profile update task.

Parameters:: payload – Task payload containing email and enabled fields.
Returns:: dict with success status.