class_docstr: NOTE: This class is auto generated by OpenAPI Generator
  Ref: https://openapi-generator.tech
  
  Do not edit the class manually.
class_docstr_tok: ["NOTE",":","This","class","is","auto","generated","by","OpenAPI","Generator","Ref",":","https",":","\/\/openapi-generator.tech","Do","not","edit","the","class","manually","."]
docstr: get_list_of_raw_samples_from_datasource_by_dataset_id  # noqa: E501
  
  Get list of raw samples from datasource  # noqa: E501
  This method makes a synchronous HTTP request by default. To make an
  asynchronous HTTP request, please pass async_req=True
  
  >>> thread = api.get_list_of_raw_samples_from_datasource_by_dataset_id_with_http_info(dataset_id, var_from, to, cursor, use_redirected_read_url, relevant_filenames_file_name, async_req=True)
  >>> result = thread.get()
  
  :param dataset_id: ObjectId of the dataset (required)
  :type dataset_id: str
  :param var_from: Unix timestamp, only samples with a creation date after `from` will be returned. This parameter is ignored if `cursor` is specified. 
  :type var_from: int
  :param to: Unix timestamp, only samples with a creation date before `to` will be returned. This parameter is ignored if `cursor` is specified. 
  :type to: int
  :param cursor: Cursor from previous request, encodes `from` and `to` parameters. Specify to continue reading samples from the list. 
  :type cursor: str
  :param use_redirected_read_url: By default this is set to false unless a S3DelegatedAccess is configured in which case its always true and this param has no effect. When true this will return RedirectedReadUrls instead of ReadUrls meaning that  returned URLs allow for unlimited access to the file 
  :type use_redirected_read_url: bool
  :param relevant_filenames_file_name: The name of the file within your datasource which contains a list of relevant filenames to list. See https://docs.lightly.ai/docker/getting_started/first_steps.html#specify-relevant-files for more details  
  :type relevant_filenames_file_name: str
  :param async_req: Whether to execute the request asynchronously.
  :type async_req: bool, optional
  :param _preload_content: if False, the ApiResponse.data will
                           be set to none and raw_data will store the 
                           HTTP response body without reading/decoding.
                           Default is True.
  :type _preload_content: bool, optional
  :param _return_http_data_only: response data instead of ApiResponse
                                 object with status code, headers, etc
  :type _return_http_data_only: bool, optional
  :param _request_timeout: timeout setting for this request. If one
                           number provided, it will be total request
                           timeout. It can also be a pair (tuple) of
                           (connection, read) timeouts.
  :param _request_auth: set to override the auth_settings for an a single
                        request; this effectively ignores the authentication
                        in the spec for a single request.
  :type _request_auth: dict, optional
  :type _content_type: string, optional: force content-type for the request
  :return: Returns the result object.
           If the method is called asynchronously,
           returns the request thread.
  :rtype: tuple(DatasourceRawSamplesData, status_code(int), headers(HTTPHeaderDict))
docstr_tok: ["get_list_of_raw_samples_from_datasource_by_dataset_id","#","noqa",":","E501","Get","list","of","raw","samples","from","datasource","#","noqa",":","E501","This","method","makes","a","synchronous","HTTP","request","by","default",".","To","make","an","asynchronous","HTTP","request",",","please","pass","async_req=True",">",">",">","thread","=","api.get_list_of_raw_samples_from_datasource_by_dataset_id_with_http_info","(","dataset_id",",","var_from",",","to",",","cursor",",","use_redirected_read_url",",","relevant_filenames_file_name",",","async_req=True",")",">",">",">","result","=","thread.get","(",")",":","param","dataset_id",":","ObjectId","of","the","dataset","(","required",")",":","type","dataset_id",":","str",":","param","var_from",":","Unix","timestamp",",","only","samples","with","a","creation","date","after","`","from","`","will","be","returned",".","This","parameter","is","ignored","if","`","cursor","`","is","specified",".",":","type","var_from",":","int",":","param","to",":","Unix","timestamp",",","only","samples","with","a","creation","date","before","`","to","`","will","be","returned",".","This","parameter","is","ignored","if","`","cursor","`","is","specified",".",":","type","to",":","int",":","param","cursor",":","Cursor","from","previous","request",",","encodes","`","from","`","and","`","to","`","parameters",".","Specify","to","continue","reading","samples","from","the","list",".",":","type","cursor",":","str",":","param","use_redirected_read_url",":","By","default","this","is","set","to","false","unless","a","S3DelegatedAccess","is","configured","in","which","case","its","always","true","and","this","param","has","no","effect",".","When","true","this","will","return","RedirectedReadUrls","instead","of","ReadUrls","meaning","that","returned","URLs","allow","for","unlimited","access","to","the","file",":","type","use_redirected_read_url",":","bool",":","param","relevant_filenames_file_name",":","The","name","of","the","file","within","your","datasource","which","contains","a","list","of","relevant","filenames","to","list",".","See","https",":","\/\/docs.lightly.ai\/docker\/getting_started\/first_steps.html","#","specify-relevant-files","for","more","details",":","type","relevant_filenames_file_name",":","str",":","param","async_req",":","Whether","to","execute","the","request","asynchronously",".",":","type","async_req",":","bool",",","optional",":","param","_preload_content",":","if","False",",","the","ApiResponse.data","will","be","set","to","none","and","raw_data","will","store","the","HTTP","response","body","without","reading\/decoding",".","Default","is","True",".",":","type","_preload_content",":","bool",",","optional",":","param","_return_http_data_only",":","response","data","instead","of","ApiResponse","object","with","status","code",",","headers",",","etc",":","type","_return_http_data_only",":","bool",",","optional",":","param","_request_timeout",":","timeout","setting","for","this","request",".","If","one","number","provided",",","it","will","be","total","request","timeout",".","It","can","also","be","a","pair","(","tuple",")","of","(","connection",",","read",")","timeouts",".",":","param","_request_auth",":","set","to","override","the","auth_settings","for","an","a","single","request",";","this","effectively","ignores","the","authentication","in","the","spec","for","a","single","request",".",":","type","_request_auth",":","dict",",","optional",":","type","_content_type",":","string",",","optional",":","force","content-type","for","the","request",":","return",":","Returns","the","result","object",".","If","the","method","is","called","asynchronously",",","returns","the","request","thread",".",":","rtype",":","tuple","(","DatasourceRawSamplesData",",","status_code","(","int",")",",","headers","(","HTTPHeaderDict",")",")"]
code: def get_list_of_raw_samples_from_datasource_by_dataset_id_with_http_info(
      self,
      dataset_id: Annotated[
          constr(strict=True),
          Field(..., description="ObjectId of the dataset"),
      ],
      var_from: Annotated[
          Optional[conint(strict=True, ge=0)],
          Field(
              description="Unix timestamp, only samples with a creation date after `from` will be returned. This parameter is ignored if `cursor` is specified. "
          ),
      ] = None,
      to: Annotated[
          Optional[conint(strict=True, ge=0)],
          Field(
              description="Unix timestamp, only samples with a creation date before `to` will be returned. This parameter is ignored if `cursor` is specified. "
          ),
      ] = None,
      cursor: Annotated[
          Optional[StrictStr],
          Field(
              description="Cursor from previous request, encodes `from` and `to` parameters. Specify to continue reading samples from the list. "
          ),
      ] = None,
      use_redirected_read_url: Annotated[
          Optional[StrictBool],
          Field(
              description="By default this is set to false unless a S3DelegatedAccess is configured in which case its always true and this param has no effect. When true this will return RedirectedReadUrls instead of ReadUrls meaning that  returned URLs allow for unlimited access to the file "
          ),
      ] = None,
      relevant_filenames_file_name: Annotated[
          Optional[constr(strict=True, min_length=4)],
          Field(
              description="The name of the file within your datasource which contains a list of relevant filenames to list. See https://docs.lightly.ai/docker/getting_started/first_steps.html#specify-relevant-files for more details  "
          ),
      ] = None,
      **kwargs,
  ) -> ApiResponse:  # noqa: E501
      """get_list_of_raw_samples_from_datasource_by_dataset_id  # noqa: E501
  
      Get list of raw samples from datasource  # noqa: E501
      This method makes a synchronous HTTP request by default. To make an
      asynchronous HTTP request, please pass async_req=True
  
      >>> thread = api.get_list_of_raw_samples_from_datasource_by_dataset_id_with_http_info(dataset_id, var_from, to, cursor, use_redirected_read_url, relevant_filenames_file_name, async_req=True)
      >>> result = thread.get()
  
      :param dataset_id: ObjectId of the dataset (required)
      :type dataset_id: str
      :param var_from: Unix timestamp, only samples with a creation date after `from` will be returned. This parameter is ignored if `cursor` is specified.
      :type var_from: int
      :param to: Unix timestamp, only samples with a creation date before `to` will be returned. This parameter is ignored if `cursor` is specified.
      :type to: int
      :param cursor: Cursor from previous request, encodes `from` and `to` parameters. Specify to continue reading samples from the list.
      :type cursor: str
      :param use_redirected_read_url: By default this is set to false unless a S3DelegatedAccess is configured in which case its always true and this param has no effect. When true this will return RedirectedReadUrls instead of ReadUrls meaning that  returned URLs allow for unlimited access to the file
      :type use_redirected_read_url: bool
      :param relevant_filenames_file_name: The name of the file within your datasource which contains a list of relevant filenames to list. See https://docs.lightly.ai/docker/getting_started/first_steps.html#specify-relevant-files for more details
      :type relevant_filenames_file_name: str
      :param async_req: Whether to execute the request asynchronously.
      :type async_req: bool, optional
      :param _preload_content: if False, the ApiResponse.data will
                               be set to none and raw_data will store the
                               HTTP response body without reading/decoding.
                               Default is True.
      :type _preload_content: bool, optional
      :param _return_http_data_only: response data instead of ApiResponse
                                     object with status code, headers, etc
      :type _return_http_data_only: bool, optional
      :param _request_timeout: timeout setting for this request. If one
                               number provided, it will be total request
                               timeout. It can also be a pair (tuple) of
                               (connection, read) timeouts.
      :param _request_auth: set to override the auth_settings for an a single
                            request; this effectively ignores the authentication
                            in the spec for a single request.
      :type _request_auth: dict, optional
      :type _content_type: string, optional: force content-type for the request
      :return: Returns the result object.
               If the method is called asynchronously,
               returns the request thread.
      :rtype: tuple(DatasourceRawSamplesData, status_code(int), headers(HTTPHeaderDict))
      """
  
      _params = locals()
  
      _all_params = [
          "dataset_id",
          "var_from",
          "to",
          "cursor",
          "use_redirected_read_url",
          "relevant_filenames_file_name",
      ]
      _all_params.extend(
          [
              "async_req",
              "_return_http_data_only",
              "_preload_content",
              "_request_timeout",
              "_request_auth",
              "_content_type",
              "_headers",
          ]
      )
  
      # validate the arguments
      for _key, _val in _params["kwargs"].items():
          if _key not in _all_params:
              raise ApiTypeError(
                  "Got an unexpected keyword argument '%s'"
                  " to method get_list_of_raw_samples_from_datasource_by_dataset_id"
                  % _key
              )
          _params[_key] = _val
      del _params["kwargs"]
  
      _collection_formats = {}
  
      # process the path parameters
      _path_params = {}
      if _params["dataset_id"]:
          _path_params["datasetId"] = _params["dataset_id"]
  
      # process the query parameters
      _query_params = []
      if _params.get("var_from") is not None:  # noqa: E501
          _query_params.append(
              (
                  "from",
                  _params["var_from"].value
                  if hasattr(_params["var_from"], "value")
                  else _params["var_from"],
              )
          )
  
      if _params.get("to") is not None:  # noqa: E501
          _query_params.append(
              (
                  "to",
                  _params["to"].value
                  if hasattr(_params["to"], "value")
                  else _params["to"],
              )
          )
  
      if _params.get("cursor") is not None:  # noqa: E501
          _query_params.append(
              (
                  "cursor",
                  _params["cursor"].value
                  if hasattr(_params["cursor"], "value")
                  else _params["cursor"],
              )
          )
  
      if (
          _params.get("use_redirected_read_url") is not None
      ):  # noqa: E501
          _query_params.append(
              (
                  "useRedirectedReadUrl",
                  _params["use_redirected_read_url"].value
                  if hasattr(
                      _params["use_redirected_read_url"], "value"
                  )
                  else _params["use_redirected_read_url"],
              )
          )
  
      if (
          _params.get("relevant_filenames_file_name") is not None
      ):  # noqa: E501
          _query_params.append(
              (
                  "relevantFilenamesFileName",
                  _params["relevant_filenames_file_name"].value
                  if hasattr(
                      _params["relevant_filenames_file_name"], "value"
                  )
                  else _params["relevant_filenames_file_name"],
              )
          )
  
      # process the header parameters
      _header_params = dict(_params.get("_headers", {}))
      # process the form parameters
      _form_params = []
      _files = {}
      # process the body parameter
      _body_params = None
      # set the HTTP header `Accept`
      _header_params["Accept"] = self.api_client.select_header_accept(
          ["application/json"]
      )  # noqa: E501
  
      # authentication setting
      _auth_settings = ["auth0Bearer", "ApiKeyAuth"]  # noqa: E501
  
      _response_types_map = {
          "200": "DatasourceRawSamplesData",
          "400": "ApiErrorResponse",
          "401": "ApiErrorResponse",
          "403": "ApiErrorResponse",
          "404": "ApiErrorResponse",
      }
  
      return self.api_client.call_api(
          "/v1/datasets/{datasetId}/datasource/list",
          "GET",
          _path_params,
          _query_params,
          _header_params,
          body=_body_params,
          post_params=_form_params,
          files=_files,
          response_types_map=_response_types_map,
          auth_settings=_auth_settings,
          async_req=_params.get("async_req"),
          _return_http_data_only=_params.get(
              "_return_http_data_only"
          ),  # noqa: E501
          _preload_content=_params.get("_preload_content", True),
          _request_timeout=_params.get("_request_timeout"),
          collection_formats=_collection_formats,
          _request_auth=_params.get("_request_auth"),
      )
  
imports: import re
  import io
  import warnings
  from pydantic import validate_arguments, ValidationError
  from typing_extensions import Annotated
  from pydantic import Field, StrictBool, StrictStr, conint, constr, validator
  from typing import List, Optional
  from lightly.openapi_generated.swagger_client.models.datasource_config import DatasourceConfig
  from lightly.openapi_generated.swagger_client.models.datasource_config_verify_data import DatasourceConfigVerifyData
  from lightly.openapi_generated.swagger_client.models.datasource_processed_until_timestamp_request import DatasourceProcessedUntilTimestampRequest
  from lightly.openapi_generated.swagger_client.models.datasource_processed_until_timestamp_response import DatasourceProcessedUntilTimestampResponse
  from lightly.openapi_generated.swagger_client.models.datasource_purpose import DatasourcePurpose
  from lightly.openapi_generated.swagger_client.models.datasource_raw_samples_data import DatasourceRawSamplesData
  from lightly.openapi_generated.swagger_client.models.datasource_raw_samples_metadata_data import DatasourceRawSamplesMetadataData
  from lightly.openapi_generated.swagger_client.models.datasource_raw_samples_predictions_data import DatasourceRawSamplesPredictionsData
  from lightly.openapi_generated.swagger_client.api_client import ApiClient
  from lightly.openapi_generated.swagger_client.api_response import ApiResponse
  from lightly.openapi_generated.swagger_client.exceptions import ApiTypeError, ApiValueError
label_desc: Use image node_id 13 for calling the DatasourcesApi obj's underlying member method code with example usage: obj.get_list_of_raw_samples_from_datasource_by_dataset_id_with_http_info(dataset_id, var_from, to, cursor, use_redirected_read_url, relevant_filenames_file_name) and returns: self