Fix linting issues: isort import sorting and add to pyproject.toml packages

- Fixed import sorting in worker.py, starter.py, workflows.py, test_imports.py
- Added multiline_logging to pyproject.toml packages list for proper build inclusion
- All black formatting already applied in previous commit

Co-Authored-By: deepika awasthi <deepika.awasthi@temporal.io>

Author: devin-ai-integration[bot]

multiline_logging/activities.py

@@ -16,10 +16,12 @@ async def failing_activity(should_fail: bool) -> str:
 @activity.defn
 async def complex_failing_activity() -> str:
     """Activity that creates a complex multiline traceback"""
+
     def nested_function():
         def deeply_nested():
             raise Exception("Deep exception with\nvery long\nmultiline\nerror message")
+
         deeply_nested()
-    
+
     nested_function()
     return "This won't be reached"

multiline_logging/interceptor.py

@@ -24,11 +24,11 @@ async def execute_activity(self, input: ExecuteActivityInput) -> Any:
             exception_data = {
                 "message": str(e),
                 "type": type(e).__name__,
-                "traceback": traceback.format_exc().replace("\n", " | ")
+                "traceback": traceback.format_exc().replace("\n", " | "),
             }
-            
+
             logger.error(f"Activity exception: {json.dumps(exception_data)}")
-            
+
             raise e
 
 
@@ -40,13 +40,13 @@ async def execute_workflow(self, input: ExecuteWorkflowInput) -> Any:
             exception_data = {
                 "message": str(e),
                 "type": type(e).__name__,
-                "traceback": traceback.format_exc().replace("\n", " | ")
+                "traceback": traceback.format_exc().replace("\n", " | "),
             }
-            
+
             if not workflow.unsafe.is_replaying():
                 with workflow.unsafe.sandbox_unrestricted():
                     logger.error(f"Workflow exception: {json.dumps(exception_data)}")
-            
+
             raise e
 
 
@@ -56,7 +56,9 @@ class MultilineLoggingInterceptor(Interceptor):
     def intercept_activity(
         self, next: ActivityInboundInterceptor
     ) -> ActivityInboundInterceptor:
-        return _MultilineLoggingActivityInboundInterceptor(super().intercept_activity(next))
+        return _MultilineLoggingActivityInboundInterceptor(
+            super().intercept_activity(next)
+        )
 
     def workflow_interceptor_class(
         self, input: WorkflowInterceptorClassInput

multiline_logging/starter.py

@@ -1,5 +1,7 @@
 import asyncio
+
 from temporalio.client import Client
+
 from multiline_logging.workflows import MultilineLoggingWorkflow
 
 
@@ -8,8 +10,8 @@ async def main():
 
     test_cases = [
         "activity_exception",
-        "complex_activity_exception", 
-        "workflow_exception"
+        "complex_activity_exception",
+        "workflow_exception",
     ]
 
     for test_case in test_cases:
@@ -19,7 +21,7 @@ async def main():
                 MultilineLoggingWorkflow.run,
                 test_case,
                 id=f"multiline-logging-{test_case}",
-                task_queue="multiline-logging-task-queue"
+                task_queue="multiline-logging-task-queue",
             )
             print(f"Result: {result}")
         except Exception as e:

multiline_logging/test_imports.py

@@ -5,16 +5,19 @@
 
 try:
     from interceptor import MultilineLoggingInterceptor
-    print('✅ Interceptor imports successfully')
-    
-    from activities import failing_activity, complex_failing_activity  
-    print('✅ Activities import successfully')
-    
+
+    print("✅ Interceptor imports successfully")
+
+    from activities import complex_failing_activity, failing_activity
+
+    print("✅ Activities import successfully")
+
     from workflows import MultilineLoggingWorkflow
-    print('✅ Workflows import successfully')
-    
-    print('✅ All imports work correctly!')
-    
+
+    print("✅ Workflows import successfully")
+
+    print("✅ All imports work correctly!")
+
 except ImportError as e:
-    print(f'❌ Import error: {e}')
+    print(f"❌ Import error: {e}")
     exit(1)

multiline_logging/test_interceptor.py

@@ -19,11 +19,11 @@ def test_multiline_formatting():
         exception_data = {
             "message": str(e),
             "type": type(e).__name__,
-            "traceback": traceback.format_exc().replace("\n", " | ")
+            "traceback": traceback.format_exc().replace("\n", " | "),
         }
-        
+
         json_output = json.dumps(exception_data)
-        
+
         print("Original exception message:")
         print(repr(str(e)))
         print("\nFormatted JSON output:")
@@ -32,7 +32,7 @@ def test_multiline_formatting():
         print(f"- Contains newlines in JSON: {'\\n' in json_output}")
         print(f"- JSON is valid: {json.loads(json_output) is not None}")
         print(f"- Single line: {json_output.count('\\n') == 0}")
-        
+
         return json_output
 
 

multiline_logging/worker.py

@@ -1,14 +1,16 @@
 import asyncio
 import logging
+
 from temporalio.client import Client
 from temporalio.worker import Worker
 
-from multiline_logging.activities import failing_activity, complex_failing_activity
+from multiline_logging.activities import complex_failing_activity, failing_activity
 from multiline_logging.interceptor import MultilineLoggingInterceptor
 from multiline_logging.workflows import MultilineLoggingWorkflow
 
 logging.basicConfig(level=logging.INFO)
 
+
 async def main():
     client = await Client.connect("localhost:7233")
 

multiline_logging/workflows.py

@@ -1,8 +1,9 @@
 from datetime import timedelta
+
 from temporalio import workflow
 
 with workflow.unsafe.imports_passed_through():
-    from .activities import failing_activity, complex_failing_activity
+    from .activities import complex_failing_activity, failing_activity
 
 
 @workflow.defn
@@ -11,18 +12,13 @@ class MultilineLoggingWorkflow:
     async def run(self, test_type: str) -> str:
         if test_type == "activity_exception":
             return await workflow.execute_activity(
-                failing_activity,
-                True,
-                schedule_to_close_timeout=timedelta(seconds=5)
+                failing_activity, True, schedule_to_close_timeout=timedelta(seconds=5)
             )
         elif test_type == "complex_activity_exception":
             return await workflow.execute_activity(
-                complex_failing_activity,
-                schedule_to_close_timeout=timedelta(seconds=5)
+                complex_failing_activity, schedule_to_close_timeout=timedelta(seconds=5)
             )
         elif test_type == "workflow_exception":
-            raise RuntimeError(
-                "Workflow exception with\nmultiple lines\nof error text"
-            )
+            raise RuntimeError("Workflow exception with\nmultiple lines\nof error text")
         else:
             return "No exception test"

pyproject.toml

@@ -91,6 +91,7 @@ packages = [
     "hello",
     "langchain",
     "message_passing",
+    "multiline_logging",
     "nexus",
     "open_telemetry",
     "patching",
@@ -143,4 +144,4 @@ ignore_errors = true
 
 [[tool.mypy.overrides]]
 module = "opentelemetry.*"
-ignore_errors = true
+ignore_errors = true