iO*ddlmZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZddlmZmZddlmZmZdd lmZeeZej2d d Ze d Ze d ZdZGddeZGddeZy)) annotationsN) timedelta)Path) AnnotatedAnyLiteral) user_data_dir)Fieldfield_validator) BaseSettingsSettingsConfigDict) get_loggerFASTMCP_ENV_FILEz.env)DEBUGINFOWARNINGERRORCRITICAL)warnerrorreplaceignoreiceZdZUdZeddZdZded<dZd ed <d Z d ed <dZ ded<e dZ ded<e dZ ded<y )DocketSettingszDocket worker configuration.FASTMCP_DOCKET_r) env_prefixextrafastmcpzAnnotated[str, Field(description=inspect.cleandoc('\n Name for the Docket queue. All servers/workers sharing the same name\n and backend URL will share a task queue.\n '))]namez memory://a<Annotated[str, Field(description=inspect.cleandoc('\n URL for the Docket backend. Supports:\n - memory:// - In-memory backend (single process only)\n - redis://host:port/db - Redis/Valkey backend (distributed, multi-process)\n\n Example: redis://localhost:6379/0\n\n Default is memory:// for single-process scenarios. Use Redis or Valkey\n when coordinating tasks across multiple processes (e.g., additional\n workers via the fastmcp tasks CLI).\n '))]urlNzAnnotated[str | None, Field(description=inspect.cleandoc('\n Name for the Docket worker. If None, Docket will auto-generate\n a unique worker name.\n '))] worker_name zAnnotated[int, Field(description=inspect.cleandoc('\n Maximum number of tasks the worker can process concurrently.\n '))] concurrencyi,)secondsaAnnotated[timedelta, Field(description=inspect.cleandoc("\n Task redelivery timeout. If a worker doesn't complete\n a task within this time, the task will be redelivered to another\n worker.\n "))]redelivery_timeoutzAnnotated[timedelta, Field(description=inspect.cleandoc('\n Delay between reconnection attempts when the worker\n loses connection to the Docket backend.\n '))]reconnection_delay)__name__ __module__ __qualname____doc__r model_configr__annotations__r r!r#rr%r'`/Users/bowang/.openclaw/workspace/ChatDev/.venv/lib/python3.12/site-packages/fastmcp/settings.pyrrs&%$L   : # :    *    , #  . !  r/rc eZdZUdZededdddZdHdZdId Ze e d d Z d e d<d Z de d<dZde d<dZde d<eddedZeZde d<dZde d<dZde d<dZde d<dZd e d!<d"Zd#e d$<d%Zd&e d'<d(Zde d)<d*Zd+e d,<d-Zde d.<d/Zde d0<d1Zde d2<d Z de d3<d Z!d4e d5<d Z"d6e d7<e#e$d89Z%d:e d;<d Z&de d<<d Z'de d=<d Z(d>e d?<dZ)d@e dA<dBZ*dCe dD<dEZ+dFe dG<y")JSettingszFastMCP settings.FASTMCP_r__T)renv_filerenv_nested_delimiter#nested_model_default_partial_updatevalidate_assignmentstrc|}d|vrA|jdd\}}t||std|dt||}d|vrAt||S)zz Get a setting. If the setting contains one or more `__`, it will be treated as a nested setting. r4Setting  does not exist.)splithasattrAttributeErrorgetattr)selfattrsettings parent_attrs r0 get_settingzSettings.get_settingsh dl $ 4 3 K8[1$x }r?r@rAsetattr)rBrCvaluerDrEs r0 set_settingzSettings.set_settingsg dl $ 4 3 K8[1$x }rs2 **&+ 1 H  299' 0 C D @A"U\Up`|`r/