@@ -22,32 +22,6 @@ def test_instantiation():
2222 op = OutputProcessor ()
2323 assert isinstance (op , OutputProcessor )
2424
25- def test_incoming_message ():
26- """Test incoming message processing."""
27- with TemporaryDirectory () as td :
28- op = TestOutputProcessor ()
29- om = OutputsManager ()
30- op .settings ["outputs_manager" ] = om
31- op .outputs_path = Path (td ) / "outputs"
32- # Simulate the running of a cell
33- cell_id = str (uuid4 ())
34- msg_id , msg = create_incoming_message (cell_id )
35- op .process_incoming_message ('shell' , msg )
36- assert op .get_cell_id (msg_id ) == cell_id
37- assert op .get_msg_id (cell_id ) == msg_id
38- # Clear the cell_id
39- op .clear (cell_id )
40- assert op .get_cell_id (msg_id ) is None
41- assert op .get_msg_id (cell_id ) is None
42- # Simulate the running of a cell
43- cell_id = str (uuid4 ())
44- msg_id , msg = create_incoming_message (cell_id )
45- op .process_incoming_message ('shell' , msg )
46- assert op .get_cell_id (msg_id ) == cell_id
47- assert op .get_msg_id (cell_id ) == msg_id
48- # # Run it again without clearing to ensure it self clears
49- cell_id = str (uuid4 ())
50- msg_id , msg = create_incoming_message (cell_id )
51- op .process_incoming_message ('shell' , msg )
52- assert op .get_cell_id (msg_id ) == cell_id
53- assert op .get_msg_id (cell_id ) == msg_id
25+ # TODO: Implement this
26+ def test_output_task ():
27+ pass
0 commit comments