Self-hosted models: remote code and tokenizer from the pinned revision; release 0.7.3

package.json

@@ -1,6 +1,6 @@
 {
   "name": "flujo-factory",
-  "version": "0.7.2",
+  "version": "0.7.3",
   "description": "Durable FLUJO swarm engine and Factory SDK, CLI, and MCP server",
   "license": "MIT",
   "repository": {

selfhost/modal/settings.py

@@ -167,7 +167,9 @@ def vllm_command(self):
                    '--reasoning-parser', self.reasoning_parser,
                    '--default-chat-template-kwargs', json.dumps(self.chat_template_kwargs())]
         if self.trust_remote_code:
-            command += ['--trust-remote-code']
+            # The model's own code and tokenizer come from the same pinned revision as its weights; without these flags
+            # the Hub serves the default branch's code files (transformers warns "A new version ... was downloaded").
+            command += ['--trust-remote-code', '--code-revision', self.revision, '--tokenizer-revision', self.revision]
         if self.gpu_count > 1:
             command += ['--tensor-parallel-size', str(self.gpu_count)]
         return command + list(self.extra_args) + self.variant_args()

selfhost/modal/test_settings.py

@@ -52,6 +52,10 @@ def test_nemotron_command_uses_the_release_image_mtp_and_hybrid_prefix_caching(s
             self.assertEqual(command[command.index(pair[0]) + 1], pair[1])
         for flag in ('--trust-remote-code', '--language-model-only', '--async-scheduling', '--enable-mamba-shared-prefix-checkpoint'):
             self.assertIn(flag, command)
+        # remote code and tokenizer from the same pinned revision as the weights
+        for flag in ('--revision', '--code-revision', '--tokenizer-revision'):
+            self.assertEqual(command[command.index(flag) + 1], s.revision, flag)
+        self.assertNotIn('--code-revision', resolve(QWEN, 'qwen').vllm_command(), 'no remote code, nothing to pin')
         self.assertEqual(json.loads(command[command.index('--speculative-config') + 1]), {'method': 'mtp', 'num_speculative_tokens': 1})
         self.assertEqual(s.env, {'OMP_NUM_THREADS': '1'})
         self.assertEqual(s.input_modalities, ('text',))