ServerInterface

Attributes

attributeconfig

= config

attributesettings

= settings

attributeheaders

= {'Authorization': f'Bearer {self.settings._auth}', 'Content-Type': 'application/json', 'User-Agent': f'{self.settings.tag}', 'X-Run-Id': f'{self.settings._op_id}', 'X-Run-Name': f'{self.settings._op_name}', 'X-Project-Name': f'{self.settings.project}'}

attributeheaders_num

= self.headers.copy()

attributeclient

= httpx.Client(verify=True if not self.settings.insecure_disable_ssl else False, proxy=self.settings.http_proxy or self.settings.https_proxy or None, limits=httpx.Limits(max_keepalive_connections=self.settings.x_file_stream_max_conn, max_connections=self.settings.x_file_stream_max_conn), timeout=httpx.Timeout(self.settings.x_file_stream_timeout_seconds))

attributeclient_storage

= httpx.Client(verify=not self.settings.insecure_disable_ssl, proxy=self.settings.http_proxy or self.settings.https_proxy or None, timeout=httpx.Timeout(self.settings.x_file_stream_timeout_seconds))

attributeclient_api

= httpx.Client(verify=True if not self.settings.insecure_disable_ssl else False, proxy=self.settings.http_proxy or self.settings.https_proxy or None, timeout=httpx.Timeout(self.settings.x_file_stream_timeout_seconds))

Functions

func__init__(self, config, settings) -> None

paramself

paramconfigdict

paramsettingsSettings

Returns

None

funcstart(self) -> None

paramself

Returns

None

funcpublish(self, num=None, data=None, file=None, timestamp=None, step=None) -> None

paramself

paramnumdict[str, any] | None

= None

paramdatadict[str, any] | None

= None

paramfiledict[str, any] | None

= None

paramtimestampint | None

= None

paramstepint | None

= None

Returns

None

funcstop(self) -> None

paramself

Returns

None

func_update_status(self, settings, trace=None)

paramself

paramsettings

paramtrace

= None

Returns

None

func_update_meta(self, num=None, df=None)

paramself

paramnum

= None

paramdf

= None

Returns

None

func_worker_progress(self)

paramself

Returns

None

func_worker_publish(self, e, h, q, stop, name=None)

paramself

parame

paramh

paramq

paramstop

paramname

= None

Returns

None

func_worker_storage(self, f, url, data)

paramself

paramf

paramurl

paramdata

Returns

None

func_worker_file(self, file, q)

paramself

paramfile

paramq

Returns

None

func_worker_meta(self, num=None, file=None)

paramself

paramnum

= None

paramfile

= None

Returns

None

func_queue_iter(self, q, b)

paramself

paramq

paramb

Returns

None

func_try(self, method, url, headers, content, name=None, q=None, retry=0)

paramself

parammethod

paramurl

paramheaders

paramcontent

paramname

= None

paramq

= None

paramretry

= 0

Returns

None

func_put_v1(self, url, headers, content, client, name='put')

paramself

paramurl

paramheaders

paramcontent

paramclient

paramname

= 'put'

Returns

None

func_post_v1(self, url, headers, q, client, name='post')

paramself

paramurl

paramheaders

paramq

paramclient

paramname

= 'post'

Returns

None

ServerInterface

Attributes

Functions

On this page