##// END OF EJS Templates
:bug: Remove `ls` from list of system commands to warn about
Samuel B. Johnson -
Show More
@@ -1,3695 +1,3690 b''
1 1 # -*- coding: utf-8 -*-
2 2 """Main IPython class."""
3 3
4 4 #-----------------------------------------------------------------------------
5 5 # Copyright (C) 2001 Janko Hauser <jhauser@zscout.de>
6 6 # Copyright (C) 2001-2007 Fernando Perez. <fperez@colorado.edu>
7 7 # Copyright (C) 2008-2011 The IPython Development Team
8 8 #
9 9 # Distributed under the terms of the BSD License. The full license is in
10 10 # the file COPYING, distributed as part of this software.
11 11 #-----------------------------------------------------------------------------
12 12
13 13
14 14 import abc
15 15 import ast
16 16 import atexit
17 17 import builtins as builtin_mod
18 18 import functools
19 19 import inspect
20 20 import os
21 21 import re
22 22 import runpy
23 23 import sys
24 24 import tempfile
25 25 import traceback
26 26 import types
27 27 import subprocess
28 28 import warnings
29 29 from io import open as io_open
30 30
31 31 from pathlib import Path
32 32 from pickleshare import PickleShareDB
33 33
34 34 from traitlets.config.configurable import SingletonConfigurable
35 35 from traitlets.utils.importstring import import_item
36 36 from IPython.core import oinspect
37 37 from IPython.core import magic
38 38 from IPython.core import page
39 39 from IPython.core import prefilter
40 40 from IPython.core import ultratb
41 41 from IPython.core.alias import Alias, AliasManager
42 42 from IPython.core.autocall import ExitAutocall
43 43 from IPython.core.builtin_trap import BuiltinTrap
44 44 from IPython.core.events import EventManager, available_events
45 45 from IPython.core.compilerop import CachingCompiler, check_linecache_ipython
46 46 from IPython.core.debugger import InterruptiblePdb
47 47 from IPython.core.display_trap import DisplayTrap
48 48 from IPython.core.displayhook import DisplayHook
49 49 from IPython.core.displaypub import DisplayPublisher
50 50 from IPython.core.error import InputRejected, UsageError
51 51 from IPython.core.extensions import ExtensionManager
52 52 from IPython.core.formatters import DisplayFormatter
53 53 from IPython.core.history import HistoryManager
54 54 from IPython.core.inputtransformer2 import ESC_MAGIC, ESC_MAGIC2
55 55 from IPython.core.logger import Logger
56 56 from IPython.core.macro import Macro
57 57 from IPython.core.payload import PayloadManager
58 58 from IPython.core.prefilter import PrefilterManager
59 59 from IPython.core.profiledir import ProfileDir
60 60 from IPython.core.usage import default_banner
61 61 from IPython.display import display
62 62 from IPython.testing.skipdoctest import skip_doctest
63 63 from IPython.utils import PyColorize
64 64 from IPython.utils import io
65 65 from IPython.utils import py3compat
66 66 from IPython.utils import openpy
67 67 from IPython.utils.decorators import undoc
68 68 from IPython.utils.io import ask_yes_no
69 69 from IPython.utils.ipstruct import Struct
70 70 from IPython.paths import get_ipython_dir
71 71 from IPython.utils.path import get_home_dir, get_py_filename, ensure_dir_exists
72 72 from IPython.utils.process import system, getoutput
73 73 from IPython.utils.strdispatch import StrDispatch
74 74 from IPython.utils.syspathcontext import prepended_to_syspath
75 75 from IPython.utils.text import format_screen, LSString, SList, DollarFormatter
76 76 from IPython.utils.tempdir import TemporaryDirectory
77 77 from traitlets import (
78 78 Integer, Bool, CaselessStrEnum, Enum, List, Dict, Unicode, Instance, Type,
79 79 observe, default, validate, Any
80 80 )
81 81 from warnings import warn
82 82 from logging import error
83 83 import IPython.core.hooks
84 84
85 85 from typing import List as ListType, Tuple, Optional, Callable
86 86 from ast import stmt
87 87
88 88 sphinxify: Optional[Callable]
89 89
90 90 try:
91 91 import docrepr.sphinxify as sphx
92 92
93 93 def sphinxify(oinfo):
94 94 wrapped_docstring = sphx.wrap_main_docstring(oinfo)
95 95
96 96 def sphinxify_docstring(docstring):
97 97 with TemporaryDirectory() as dirname:
98 98 return {
99 99 "text/html": sphx.sphinxify(wrapped_docstring, dirname),
100 100 "text/plain": docstring,
101 101 }
102 102
103 103 return sphinxify_docstring
104 104 except ImportError:
105 105 sphinxify = None
106 106
107 107
108 108 class ProvisionalWarning(DeprecationWarning):
109 109 """
110 110 Warning class for unstable features
111 111 """
112 112 pass
113 113
114 114 from ast import Module
115 115
116 116 _assign_nodes = (ast.AugAssign, ast.AnnAssign, ast.Assign)
117 117 _single_targets_nodes = (ast.AugAssign, ast.AnnAssign)
118 118
119 119 #-----------------------------------------------------------------------------
120 120 # Await Helpers
121 121 #-----------------------------------------------------------------------------
122 122
123 123 # we still need to run things using the asyncio eventloop, but there is no
124 124 # async integration
125 125 from .async_helpers import _asyncio_runner, _pseudo_sync_runner
126 126 from .async_helpers import _curio_runner, _trio_runner, _should_be_async
127 127
128 128 #-----------------------------------------------------------------------------
129 129 # Globals
130 130 #-----------------------------------------------------------------------------
131 131
132 132 # compiled regexps for autoindent management
133 133 dedent_re = re.compile(r'^\s+raise|^\s+return|^\s+pass')
134 134
135 135 #-----------------------------------------------------------------------------
136 136 # Utilities
137 137 #-----------------------------------------------------------------------------
138 138
139 139 @undoc
140 140 def softspace(file, newvalue):
141 141 """Copied from code.py, to remove the dependency"""
142 142
143 143 oldvalue = 0
144 144 try:
145 145 oldvalue = file.softspace
146 146 except AttributeError:
147 147 pass
148 148 try:
149 149 file.softspace = newvalue
150 150 except (AttributeError, TypeError):
151 151 # "attribute-less object" or "read-only attributes"
152 152 pass
153 153 return oldvalue
154 154
155 155 @undoc
156 156 def no_op(*a, **kw):
157 157 pass
158 158
159 159
160 160 class SpaceInInput(Exception): pass
161 161
162 162
163 163 class SeparateUnicode(Unicode):
164 164 r"""A Unicode subclass to validate separate_in, separate_out, etc.
165 165
166 166 This is a Unicode based trait that converts '0'->'' and ``'\\n'->'\n'``.
167 167 """
168 168
169 169 def validate(self, obj, value):
170 170 if value == '0': value = ''
171 171 value = value.replace('\\n','\n')
172 172 return super(SeparateUnicode, self).validate(obj, value)
173 173
174 174
175 175 @undoc
176 176 class DummyMod(object):
177 177 """A dummy module used for IPython's interactive module when
178 178 a namespace must be assigned to the module's __dict__."""
179 179 __spec__ = None
180 180
181 181
182 182 class ExecutionInfo(object):
183 183 """The arguments used for a call to :meth:`InteractiveShell.run_cell`
184 184
185 185 Stores information about what is going to happen.
186 186 """
187 187 raw_cell = None
188 188 store_history = False
189 189 silent = False
190 190 shell_futures = True
191 191
192 192 def __init__(self, raw_cell, store_history, silent, shell_futures):
193 193 self.raw_cell = raw_cell
194 194 self.store_history = store_history
195 195 self.silent = silent
196 196 self.shell_futures = shell_futures
197 197
198 198 def __repr__(self):
199 199 name = self.__class__.__qualname__
200 200 raw_cell = ((self.raw_cell[:50] + '..')
201 201 if len(self.raw_cell) > 50 else self.raw_cell)
202 202 return '<%s object at %x, raw_cell="%s" store_history=%s silent=%s shell_futures=%s>' %\
203 203 (name, id(self), raw_cell, self.store_history, self.silent, self.shell_futures)
204 204
205 205
206 206 class ExecutionResult(object):
207 207 """The result of a call to :meth:`InteractiveShell.run_cell`
208 208
209 209 Stores information about what took place.
210 210 """
211 211 execution_count = None
212 212 error_before_exec = None
213 213 error_in_exec: Optional[BaseException] = None
214 214 info = None
215 215 result = None
216 216
217 217 def __init__(self, info):
218 218 self.info = info
219 219
220 220 @property
221 221 def success(self):
222 222 return (self.error_before_exec is None) and (self.error_in_exec is None)
223 223
224 224 def raise_error(self):
225 225 """Reraises error if `success` is `False`, otherwise does nothing"""
226 226 if self.error_before_exec is not None:
227 227 raise self.error_before_exec
228 228 if self.error_in_exec is not None:
229 229 raise self.error_in_exec
230 230
231 231 def __repr__(self):
232 232 name = self.__class__.__qualname__
233 233 return '<%s object at %x, execution_count=%s error_before_exec=%s error_in_exec=%s info=%s result=%s>' %\
234 234 (name, id(self), self.execution_count, self.error_before_exec, self.error_in_exec, repr(self.info), repr(self.result))
235 235
236 236
237 237 class InteractiveShell(SingletonConfigurable):
238 238 """An enhanced, interactive shell for Python."""
239 239
240 240 _instance = None
241 241
242 242 ast_transformers = List([], help=
243 243 """
244 244 A list of ast.NodeTransformer subclass instances, which will be applied
245 245 to user input before code is run.
246 246 """
247 247 ).tag(config=True)
248 248
249 249 autocall = Enum((0,1,2), default_value=0, help=
250 250 """
251 251 Make IPython automatically call any callable object even if you didn't
252 252 type explicit parentheses. For example, 'str 43' becomes 'str(43)'
253 253 automatically. The value can be '0' to disable the feature, '1' for
254 254 'smart' autocall, where it is not applied if there are no more
255 255 arguments on the line, and '2' for 'full' autocall, where all callable
256 256 objects are automatically called (even if no arguments are present).
257 257 """
258 258 ).tag(config=True)
259 259
260 260 autoindent = Bool(True, help=
261 261 """
262 262 Autoindent IPython code entered interactively.
263 263 """
264 264 ).tag(config=True)
265 265
266 266 autoawait = Bool(True, help=
267 267 """
268 268 Automatically run await statement in the top level repl.
269 269 """
270 270 ).tag(config=True)
271 271
272 272 loop_runner_map ={
273 273 'asyncio':(_asyncio_runner, True),
274 274 'curio':(_curio_runner, True),
275 275 'trio':(_trio_runner, True),
276 276 'sync': (_pseudo_sync_runner, False)
277 277 }
278 278
279 279 loop_runner = Any(default_value="IPython.core.interactiveshell._asyncio_runner",
280 280 allow_none=True,
281 281 help="""Select the loop runner that will be used to execute top-level asynchronous code"""
282 282 ).tag(config=True)
283 283
284 284 @default('loop_runner')
285 285 def _default_loop_runner(self):
286 286 return import_item("IPython.core.interactiveshell._asyncio_runner")
287 287
288 288 @validate('loop_runner')
289 289 def _import_runner(self, proposal):
290 290 if isinstance(proposal.value, str):
291 291 if proposal.value in self.loop_runner_map:
292 292 runner, autoawait = self.loop_runner_map[proposal.value]
293 293 self.autoawait = autoawait
294 294 return runner
295 295 runner = import_item(proposal.value)
296 296 if not callable(runner):
297 297 raise ValueError('loop_runner must be callable')
298 298 return runner
299 299 if not callable(proposal.value):
300 300 raise ValueError('loop_runner must be callable')
301 301 return proposal.value
302 302
303 303 automagic = Bool(True, help=
304 304 """
305 305 Enable magic commands to be called without the leading %.
306 306 """
307 307 ).tag(config=True)
308 308
309 309 banner1 = Unicode(default_banner,
310 310 help="""The part of the banner to be printed before the profile"""
311 311 ).tag(config=True)
312 312 banner2 = Unicode('',
313 313 help="""The part of the banner to be printed after the profile"""
314 314 ).tag(config=True)
315 315
316 316 cache_size = Integer(1000, help=
317 317 """
318 318 Set the size of the output cache. The default is 1000, you can
319 319 change it permanently in your config file. Setting it to 0 completely
320 320 disables the caching system, and the minimum value accepted is 3 (if
321 321 you provide a value less than 3, it is reset to 0 and a warning is
322 322 issued). This limit is defined because otherwise you'll spend more
323 323 time re-flushing a too small cache than working
324 324 """
325 325 ).tag(config=True)
326 326 color_info = Bool(True, help=
327 327 """
328 328 Use colors for displaying information about objects. Because this
329 329 information is passed through a pager (like 'less'), and some pagers
330 330 get confused with color codes, this capability can be turned off.
331 331 """
332 332 ).tag(config=True)
333 333 colors = CaselessStrEnum(('Neutral', 'NoColor','LightBG','Linux'),
334 334 default_value='Neutral',
335 335 help="Set the color scheme (NoColor, Neutral, Linux, or LightBG)."
336 336 ).tag(config=True)
337 337 debug = Bool(False).tag(config=True)
338 338 disable_failing_post_execute = Bool(False,
339 339 help="Don't call post-execute functions that have failed in the past."
340 340 ).tag(config=True)
341 341 display_formatter = Instance(DisplayFormatter, allow_none=True)
342 342 displayhook_class = Type(DisplayHook)
343 343 display_pub_class = Type(DisplayPublisher)
344 344 compiler_class = Type(CachingCompiler)
345 345
346 346 sphinxify_docstring = Bool(False, help=
347 347 """
348 348 Enables rich html representation of docstrings. (This requires the
349 349 docrepr module).
350 350 """).tag(config=True)
351 351
352 352 @observe("sphinxify_docstring")
353 353 def _sphinxify_docstring_changed(self, change):
354 354 if change['new']:
355 355 warn("`sphinxify_docstring` is provisional since IPython 5.0 and might change in future versions." , ProvisionalWarning)
356 356
357 357 enable_html_pager = Bool(False, help=
358 358 """
359 359 (Provisional API) enables html representation in mime bundles sent
360 360 to pagers.
361 361 """).tag(config=True)
362 362
363 363 @observe("enable_html_pager")
364 364 def _enable_html_pager_changed(self, change):
365 365 if change['new']:
366 366 warn("`enable_html_pager` is provisional since IPython 5.0 and might change in future versions.", ProvisionalWarning)
367 367
368 368 data_pub_class = None
369 369
370 370 exit_now = Bool(False)
371 371 exiter = Instance(ExitAutocall)
372 372 @default('exiter')
373 373 def _exiter_default(self):
374 374 return ExitAutocall(self)
375 375 # Monotonically increasing execution counter
376 376 execution_count = Integer(1)
377 377 filename = Unicode("<ipython console>")
378 378 ipython_dir= Unicode('').tag(config=True) # Set to get_ipython_dir() in __init__
379 379
380 380 # Used to transform cells before running them, and check whether code is complete
381 381 input_transformer_manager = Instance('IPython.core.inputtransformer2.TransformerManager',
382 382 ())
383 383
384 384 @property
385 385 def input_transformers_cleanup(self):
386 386 return self.input_transformer_manager.cleanup_transforms
387 387
388 388 input_transformers_post = List([],
389 389 help="A list of string input transformers, to be applied after IPython's "
390 390 "own input transformations."
391 391 )
392 392
393 393 @property
394 394 def input_splitter(self):
395 395 """Make this available for backward compatibility (pre-7.0 release) with existing code.
396 396
397 397 For example, ipykernel ipykernel currently uses
398 398 `shell.input_splitter.check_complete`
399 399 """
400 400 from warnings import warn
401 401 warn("`input_splitter` is deprecated since IPython 7.0, prefer `input_transformer_manager`.",
402 402 DeprecationWarning, stacklevel=2
403 403 )
404 404 return self.input_transformer_manager
405 405
406 406 logstart = Bool(False, help=
407 407 """
408 408 Start logging to the default log file in overwrite mode.
409 409 Use `logappend` to specify a log file to **append** logs to.
410 410 """
411 411 ).tag(config=True)
412 412 logfile = Unicode('', help=
413 413 """
414 414 The name of the logfile to use.
415 415 """
416 416 ).tag(config=True)
417 417 logappend = Unicode('', help=
418 418 """
419 419 Start logging to the given file in append mode.
420 420 Use `logfile` to specify a log file to **overwrite** logs to.
421 421 """
422 422 ).tag(config=True)
423 423 object_info_string_level = Enum((0,1,2), default_value=0,
424 424 ).tag(config=True)
425 425 pdb = Bool(False, help=
426 426 """
427 427 Automatically call the pdb debugger after every exception.
428 428 """
429 429 ).tag(config=True)
430 430 display_page = Bool(False,
431 431 help="""If True, anything that would be passed to the pager
432 432 will be displayed as regular output instead."""
433 433 ).tag(config=True)
434 434
435 435
436 436 show_rewritten_input = Bool(True,
437 437 help="Show rewritten input, e.g. for autocall."
438 438 ).tag(config=True)
439 439
440 440 quiet = Bool(False).tag(config=True)
441 441
442 442 history_length = Integer(10000,
443 443 help='Total length of command history'
444 444 ).tag(config=True)
445 445
446 446 history_load_length = Integer(1000, help=
447 447 """
448 448 The number of saved history entries to be loaded
449 449 into the history buffer at startup.
450 450 """
451 451 ).tag(config=True)
452 452
453 453 ast_node_interactivity = Enum(['all', 'last', 'last_expr', 'none', 'last_expr_or_assign'],
454 454 default_value='last_expr',
455 455 help="""
456 456 'all', 'last', 'last_expr' or 'none', 'last_expr_or_assign' specifying
457 457 which nodes should be run interactively (displaying output from expressions).
458 458 """
459 459 ).tag(config=True)
460 460
461 461 # TODO: this part of prompt management should be moved to the frontends.
462 462 # Use custom TraitTypes that convert '0'->'' and '\\n'->'\n'
463 463 separate_in = SeparateUnicode('\n').tag(config=True)
464 464 separate_out = SeparateUnicode('').tag(config=True)
465 465 separate_out2 = SeparateUnicode('').tag(config=True)
466 466 wildcards_case_sensitive = Bool(True).tag(config=True)
467 467 xmode = CaselessStrEnum(('Context', 'Plain', 'Verbose', 'Minimal'),
468 468 default_value='Context',
469 469 help="Switch modes for the IPython exception handlers."
470 470 ).tag(config=True)
471 471
472 472 # Subcomponents of InteractiveShell
473 473 alias_manager = Instance('IPython.core.alias.AliasManager', allow_none=True)
474 474 prefilter_manager = Instance('IPython.core.prefilter.PrefilterManager', allow_none=True)
475 475 builtin_trap = Instance('IPython.core.builtin_trap.BuiltinTrap', allow_none=True)
476 476 display_trap = Instance('IPython.core.display_trap.DisplayTrap', allow_none=True)
477 477 extension_manager = Instance('IPython.core.extensions.ExtensionManager', allow_none=True)
478 478 payload_manager = Instance('IPython.core.payload.PayloadManager', allow_none=True)
479 479 history_manager = Instance('IPython.core.history.HistoryAccessorBase', allow_none=True)
480 480 magics_manager = Instance('IPython.core.magic.MagicsManager', allow_none=True)
481 481
482 482 profile_dir = Instance('IPython.core.application.ProfileDir', allow_none=True)
483 483 @property
484 484 def profile(self):
485 485 if self.profile_dir is not None:
486 486 name = os.path.basename(self.profile_dir.location)
487 487 return name.replace('profile_','')
488 488
489 489
490 490 # Private interface
491 491 _post_execute = Dict()
492 492
493 493 # Tracks any GUI loop loaded for pylab
494 494 pylab_gui_select = None
495 495
496 496 last_execution_succeeded = Bool(True, help='Did last executed command succeeded')
497 497
498 498 last_execution_result = Instance('IPython.core.interactiveshell.ExecutionResult', help='Result of executing the last command', allow_none=True)
499 499
500 500 def __init__(self, ipython_dir=None, profile_dir=None,
501 501 user_module=None, user_ns=None,
502 502 custom_exceptions=((), None), **kwargs):
503 503 # This is where traits with a config_key argument are updated
504 504 # from the values on config.
505 505 super(InteractiveShell, self).__init__(**kwargs)
506 506 if 'PromptManager' in self.config:
507 507 warn('As of IPython 5.0 `PromptManager` config will have no effect'
508 508 ' and has been replaced by TerminalInteractiveShell.prompts_class')
509 509 self.configurables = [self]
510 510
511 511 # These are relatively independent and stateless
512 512 self.init_ipython_dir(ipython_dir)
513 513 self.init_profile_dir(profile_dir)
514 514 self.init_instance_attrs()
515 515 self.init_environment()
516 516
517 517 # Check if we're in a virtualenv, and set up sys.path.
518 518 self.init_virtualenv()
519 519
520 520 # Create namespaces (user_ns, user_global_ns, etc.)
521 521 self.init_create_namespaces(user_module, user_ns)
522 522 # This has to be done after init_create_namespaces because it uses
523 523 # something in self.user_ns, but before init_sys_modules, which
524 524 # is the first thing to modify sys.
525 525 # TODO: When we override sys.stdout and sys.stderr before this class
526 526 # is created, we are saving the overridden ones here. Not sure if this
527 527 # is what we want to do.
528 528 self.save_sys_module_state()
529 529 self.init_sys_modules()
530 530
531 531 # While we're trying to have each part of the code directly access what
532 532 # it needs without keeping redundant references to objects, we have too
533 533 # much legacy code that expects ip.db to exist.
534 534 self.db = PickleShareDB(os.path.join(self.profile_dir.location, 'db'))
535 535
536 536 self.init_history()
537 537 self.init_encoding()
538 538 self.init_prefilter()
539 539
540 540 self.init_syntax_highlighting()
541 541 self.init_hooks()
542 542 self.init_events()
543 543 self.init_pushd_popd_magic()
544 544 self.init_user_ns()
545 545 self.init_logger()
546 546 self.init_builtins()
547 547
548 548 # The following was in post_config_initialization
549 549 self.init_inspector()
550 550 self.raw_input_original = input
551 551 self.init_completer()
552 552 # TODO: init_io() needs to happen before init_traceback handlers
553 553 # because the traceback handlers hardcode the stdout/stderr streams.
554 554 # This logic in in debugger.Pdb and should eventually be changed.
555 555 self.init_io()
556 556 self.init_traceback_handlers(custom_exceptions)
557 557 self.init_prompts()
558 558 self.init_display_formatter()
559 559 self.init_display_pub()
560 560 self.init_data_pub()
561 561 self.init_displayhook()
562 562 self.init_magics()
563 563 self.init_alias()
564 564 self.init_logstart()
565 565 self.init_pdb()
566 566 self.init_extension_manager()
567 567 self.init_payload()
568 568 self.events.trigger('shell_initialized', self)
569 569 atexit.register(self.atexit_operations)
570 570
571 571 # The trio runner is used for running Trio in the foreground thread. It
572 572 # is different from `_trio_runner(async_fn)` in `async_helpers.py`
573 573 # which calls `trio.run()` for every cell. This runner runs all cells
574 574 # inside a single Trio event loop. If used, it is set from
575 575 # `ipykernel.kernelapp`.
576 576 self.trio_runner = None
577 577
578 578 def get_ipython(self):
579 579 """Return the currently running IPython instance."""
580 580 return self
581 581
582 582 #-------------------------------------------------------------------------
583 583 # Trait changed handlers
584 584 #-------------------------------------------------------------------------
585 585 @observe('ipython_dir')
586 586 def _ipython_dir_changed(self, change):
587 587 ensure_dir_exists(change['new'])
588 588
589 589 def set_autoindent(self,value=None):
590 590 """Set the autoindent flag.
591 591
592 592 If called with no arguments, it acts as a toggle."""
593 593 if value is None:
594 594 self.autoindent = not self.autoindent
595 595 else:
596 596 self.autoindent = value
597 597
598 598 def set_trio_runner(self, tr):
599 599 self.trio_runner = tr
600 600
601 601 #-------------------------------------------------------------------------
602 602 # init_* methods called by __init__
603 603 #-------------------------------------------------------------------------
604 604
605 605 def init_ipython_dir(self, ipython_dir):
606 606 if ipython_dir is not None:
607 607 self.ipython_dir = ipython_dir
608 608 return
609 609
610 610 self.ipython_dir = get_ipython_dir()
611 611
612 612 def init_profile_dir(self, profile_dir):
613 613 if profile_dir is not None:
614 614 self.profile_dir = profile_dir
615 615 return
616 616 self.profile_dir = ProfileDir.create_profile_dir_by_name(
617 617 self.ipython_dir, "default"
618 618 )
619 619
620 620 def init_instance_attrs(self):
621 621 self.more = False
622 622
623 623 # command compiler
624 624 self.compile = self.compiler_class()
625 625
626 626 # Make an empty namespace, which extension writers can rely on both
627 627 # existing and NEVER being used by ipython itself. This gives them a
628 628 # convenient location for storing additional information and state
629 629 # their extensions may require, without fear of collisions with other
630 630 # ipython names that may develop later.
631 631 self.meta = Struct()
632 632
633 633 # Temporary files used for various purposes. Deleted at exit.
634 634 # The files here are stored with Path from Pathlib
635 635 self.tempfiles = []
636 636 self.tempdirs = []
637 637
638 638 # keep track of where we started running (mainly for crash post-mortem)
639 639 # This is not being used anywhere currently.
640 640 self.starting_dir = os.getcwd()
641 641
642 642 # Indentation management
643 643 self.indent_current_nsp = 0
644 644
645 645 # Dict to track post-execution functions that have been registered
646 646 self._post_execute = {}
647 647
648 648 def init_environment(self):
649 649 """Any changes we need to make to the user's environment."""
650 650 pass
651 651
652 652 def init_encoding(self):
653 653 # Get system encoding at startup time. Certain terminals (like Emacs
654 654 # under Win32 have it set to None, and we need to have a known valid
655 655 # encoding to use in the raw_input() method
656 656 try:
657 657 self.stdin_encoding = sys.stdin.encoding or 'ascii'
658 658 except AttributeError:
659 659 self.stdin_encoding = 'ascii'
660 660
661 661
662 662 @observe('colors')
663 663 def init_syntax_highlighting(self, changes=None):
664 664 # Python source parser/formatter for syntax highlighting
665 665 pyformat = PyColorize.Parser(style=self.colors, parent=self).format
666 666 self.pycolorize = lambda src: pyformat(src,'str')
667 667
668 668 def refresh_style(self):
669 669 # No-op here, used in subclass
670 670 pass
671 671
672 672 def init_pushd_popd_magic(self):
673 673 # for pushd/popd management
674 674 self.home_dir = get_home_dir()
675 675
676 676 self.dir_stack = []
677 677
678 678 def init_logger(self):
679 679 self.logger = Logger(self.home_dir, logfname='ipython_log.py',
680 680 logmode='rotate')
681 681
682 682 def init_logstart(self):
683 683 """Initialize logging in case it was requested at the command line.
684 684 """
685 685 if self.logappend:
686 686 self.magic('logstart %s append' % self.logappend)
687 687 elif self.logfile:
688 688 self.magic('logstart %s' % self.logfile)
689 689 elif self.logstart:
690 690 self.magic('logstart')
691 691
692 692
693 693 def init_builtins(self):
694 694 # A single, static flag that we set to True. Its presence indicates
695 695 # that an IPython shell has been created, and we make no attempts at
696 696 # removing on exit or representing the existence of more than one
697 697 # IPython at a time.
698 698 builtin_mod.__dict__['__IPYTHON__'] = True
699 699 builtin_mod.__dict__['display'] = display
700 700
701 701 self.builtin_trap = BuiltinTrap(shell=self)
702 702
703 703 @observe('colors')
704 704 def init_inspector(self, changes=None):
705 705 # Object inspector
706 706 self.inspector = oinspect.Inspector(oinspect.InspectColors,
707 707 PyColorize.ANSICodeColors,
708 708 self.colors,
709 709 self.object_info_string_level)
710 710
711 711 def init_io(self):
712 712 # implemented in subclasses, TerminalInteractiveShell does call
713 713 # colorama.init().
714 714 pass
715 715
716 716 def init_prompts(self):
717 717 # Set system prompts, so that scripts can decide if they are running
718 718 # interactively.
719 719 sys.ps1 = 'In : '
720 720 sys.ps2 = '...: '
721 721 sys.ps3 = 'Out: '
722 722
723 723 def init_display_formatter(self):
724 724 self.display_formatter = DisplayFormatter(parent=self)
725 725 self.configurables.append(self.display_formatter)
726 726
727 727 def init_display_pub(self):
728 728 self.display_pub = self.display_pub_class(parent=self, shell=self)
729 729 self.configurables.append(self.display_pub)
730 730
731 731 def init_data_pub(self):
732 732 if not self.data_pub_class:
733 733 self.data_pub = None
734 734 return
735 735 self.data_pub = self.data_pub_class(parent=self)
736 736 self.configurables.append(self.data_pub)
737 737
738 738 def init_displayhook(self):
739 739 # Initialize displayhook, set in/out prompts and printing system
740 740 self.displayhook = self.displayhook_class(
741 741 parent=self,
742 742 shell=self,
743 743 cache_size=self.cache_size,
744 744 )
745 745 self.configurables.append(self.displayhook)
746 746 # This is a context manager that installs/revmoes the displayhook at
747 747 # the appropriate time.
748 748 self.display_trap = DisplayTrap(hook=self.displayhook)
749 749
750 750 def init_virtualenv(self):
751 751 """Add the current virtualenv to sys.path so the user can import modules from it.
752 752 This isn't perfect: it doesn't use the Python interpreter with which the
753 753 virtualenv was built, and it ignores the --no-site-packages option. A
754 754 warning will appear suggesting the user installs IPython in the
755 755 virtualenv, but for many cases, it probably works well enough.
756 756
757 757 Adapted from code snippets online.
758 758
759 759 http://blog.ufsoft.org/2009/1/29/ipython-and-virtualenv
760 760 """
761 761 if 'VIRTUAL_ENV' not in os.environ:
762 762 # Not in a virtualenv
763 763 return
764 764 elif os.environ["VIRTUAL_ENV"] == "":
765 765 warn("Virtual env path set to '', please check if this is intended.")
766 766 return
767 767
768 768 p = Path(sys.executable)
769 769 p_venv = Path(os.environ["VIRTUAL_ENV"])
770 770
771 771 # fallback venv detection:
772 772 # stdlib venv may symlink sys.executable, so we can't use realpath.
773 773 # but others can symlink *to* the venv Python, so we can't just use sys.executable.
774 774 # So we just check every item in the symlink tree (generally <= 3)
775 775 paths = [p]
776 776 while p.is_symlink():
777 777 p = Path(os.readlink(p))
778 778 paths.append(p.resolve())
779 779
780 780 # In Cygwin paths like "c:\..." and '\cygdrive\c\...' are possible
781 781 if p_venv.parts[1] == "cygdrive":
782 782 drive_name = p_venv.parts[2]
783 783 p_venv = (drive_name + ":/") / Path(*p_venv.parts[3:])
784 784
785 785 if any(p_venv == p.parents[1] for p in paths):
786 786 # Our exe is inside or has access to the virtualenv, don't need to do anything.
787 787 return
788 788
789 789 if sys.platform == "win32":
790 790 virtual_env = str(Path(os.environ["VIRTUAL_ENV"], "Lib", "site-packages"))
791 791 else:
792 792 virtual_env_path = Path(
793 793 os.environ["VIRTUAL_ENV"], "lib", "python{}.{}", "site-packages"
794 794 )
795 795 p_ver = sys.version_info[:2]
796 796
797 797 # Predict version from py[thon]-x.x in the $VIRTUAL_ENV
798 798 re_m = re.search(r"\bpy(?:thon)?([23])\.(\d+)\b", os.environ["VIRTUAL_ENV"])
799 799 if re_m:
800 800 predicted_path = Path(str(virtual_env_path).format(*re_m.groups()))
801 801 if predicted_path.exists():
802 802 p_ver = re_m.groups()
803 803
804 804 virtual_env = str(virtual_env_path).format(*p_ver)
805 805
806 806 warn(
807 807 "Attempting to work in a virtualenv. If you encounter problems, "
808 808 "please install IPython inside the virtualenv."
809 809 )
810 810 import site
811 811 sys.path.insert(0, virtual_env)
812 812 site.addsitedir(virtual_env)
813 813
814 814 #-------------------------------------------------------------------------
815 815 # Things related to injections into the sys module
816 816 #-------------------------------------------------------------------------
817 817
818 818 def save_sys_module_state(self):
819 819 """Save the state of hooks in the sys module.
820 820
821 821 This has to be called after self.user_module is created.
822 822 """
823 823 self._orig_sys_module_state = {'stdin': sys.stdin,
824 824 'stdout': sys.stdout,
825 825 'stderr': sys.stderr,
826 826 'excepthook': sys.excepthook}
827 827 self._orig_sys_modules_main_name = self.user_module.__name__
828 828 self._orig_sys_modules_main_mod = sys.modules.get(self.user_module.__name__)
829 829
830 830 def restore_sys_module_state(self):
831 831 """Restore the state of the sys module."""
832 832 try:
833 833 for k, v in self._orig_sys_module_state.items():
834 834 setattr(sys, k, v)
835 835 except AttributeError:
836 836 pass
837 837 # Reset what what done in self.init_sys_modules
838 838 if self._orig_sys_modules_main_mod is not None:
839 839 sys.modules[self._orig_sys_modules_main_name] = self._orig_sys_modules_main_mod
840 840
841 841 #-------------------------------------------------------------------------
842 842 # Things related to the banner
843 843 #-------------------------------------------------------------------------
844 844
845 845 @property
846 846 def banner(self):
847 847 banner = self.banner1
848 848 if self.profile and self.profile != 'default':
849 849 banner += '\nIPython profile: %s\n' % self.profile
850 850 if self.banner2:
851 851 banner += '\n' + self.banner2
852 852 return banner
853 853
854 854 def show_banner(self, banner=None):
855 855 if banner is None:
856 856 banner = self.banner
857 857 sys.stdout.write(banner)
858 858
859 859 #-------------------------------------------------------------------------
860 860 # Things related to hooks
861 861 #-------------------------------------------------------------------------
862 862
863 863 def init_hooks(self):
864 864 # hooks holds pointers used for user-side customizations
865 865 self.hooks = Struct()
866 866
867 867 self.strdispatchers = {}
868 868
869 869 # Set all default hooks, defined in the IPython.hooks module.
870 870 hooks = IPython.core.hooks
871 871 for hook_name in hooks.__all__:
872 872 # default hooks have priority 100, i.e. low; user hooks should have
873 873 # 0-100 priority
874 874 self.set_hook(hook_name, getattr(hooks, hook_name), 100)
875 875
876 876 if self.display_page:
877 877 self.set_hook('show_in_pager', page.as_hook(page.display_page), 90)
878 878
879 879 def set_hook(self, name, hook, priority=50, str_key=None, re_key=None):
880 880 """set_hook(name,hook) -> sets an internal IPython hook.
881 881
882 882 IPython exposes some of its internal API as user-modifiable hooks. By
883 883 adding your function to one of these hooks, you can modify IPython's
884 884 behavior to call at runtime your own routines."""
885 885
886 886 # At some point in the future, this should validate the hook before it
887 887 # accepts it. Probably at least check that the hook takes the number
888 888 # of args it's supposed to.
889 889
890 890 f = types.MethodType(hook,self)
891 891
892 892 # check if the hook is for strdispatcher first
893 893 if str_key is not None:
894 894 sdp = self.strdispatchers.get(name, StrDispatch())
895 895 sdp.add_s(str_key, f, priority )
896 896 self.strdispatchers[name] = sdp
897 897 return
898 898 if re_key is not None:
899 899 sdp = self.strdispatchers.get(name, StrDispatch())
900 900 sdp.add_re(re.compile(re_key), f, priority )
901 901 self.strdispatchers[name] = sdp
902 902 return
903 903
904 904 dp = getattr(self.hooks, name, None)
905 905 if name not in IPython.core.hooks.__all__:
906 906 print("Warning! Hook '%s' is not one of %s" % \
907 907 (name, IPython.core.hooks.__all__ ))
908 908
909 909 if name in IPython.core.hooks.deprecated:
910 910 alternative = IPython.core.hooks.deprecated[name]
911 911 raise ValueError(
912 912 "Hook {} has been deprecated since IPython 5.0. Use {} instead.".format(
913 913 name, alternative
914 914 )
915 915 )
916 916
917 917 if not dp:
918 918 dp = IPython.core.hooks.CommandChainDispatcher()
919 919
920 920 try:
921 921 dp.add(f,priority)
922 922 except AttributeError:
923 923 # it was not commandchain, plain old func - replace
924 924 dp = f
925 925
926 926 setattr(self.hooks,name, dp)
927 927
928 928 #-------------------------------------------------------------------------
929 929 # Things related to events
930 930 #-------------------------------------------------------------------------
931 931
932 932 def init_events(self):
933 933 self.events = EventManager(self, available_events)
934 934
935 935 self.events.register("pre_execute", self._clear_warning_registry)
936 936
937 937 def register_post_execute(self, func):
938 938 """DEPRECATED: Use ip.events.register('post_run_cell', func)
939 939
940 940 Register a function for calling after code execution.
941 941 """
942 942 raise ValueError(
943 943 "ip.register_post_execute is deprecated since IPython 1.0, use "
944 944 "ip.events.register('post_run_cell', func) instead."
945 945 )
946 946
947 947 def _clear_warning_registry(self):
948 948 # clear the warning registry, so that different code blocks with
949 949 # overlapping line number ranges don't cause spurious suppression of
950 950 # warnings (see gh-6611 for details)
951 951 if "__warningregistry__" in self.user_global_ns:
952 952 del self.user_global_ns["__warningregistry__"]
953 953
954 954 #-------------------------------------------------------------------------
955 955 # Things related to the "main" module
956 956 #-------------------------------------------------------------------------
957 957
958 958 def new_main_mod(self, filename, modname):
959 959 """Return a new 'main' module object for user code execution.
960 960
961 961 ``filename`` should be the path of the script which will be run in the
962 962 module. Requests with the same filename will get the same module, with
963 963 its namespace cleared.
964 964
965 965 ``modname`` should be the module name - normally either '__main__' or
966 966 the basename of the file without the extension.
967 967
968 968 When scripts are executed via %run, we must keep a reference to their
969 969 __main__ module around so that Python doesn't
970 970 clear it, rendering references to module globals useless.
971 971
972 972 This method keeps said reference in a private dict, keyed by the
973 973 absolute path of the script. This way, for multiple executions of the
974 974 same script we only keep one copy of the namespace (the last one),
975 975 thus preventing memory leaks from old references while allowing the
976 976 objects from the last execution to be accessible.
977 977 """
978 978 filename = os.path.abspath(filename)
979 979 try:
980 980 main_mod = self._main_mod_cache[filename]
981 981 except KeyError:
982 982 main_mod = self._main_mod_cache[filename] = types.ModuleType(
983 983 modname,
984 984 doc="Module created for script run in IPython")
985 985 else:
986 986 main_mod.__dict__.clear()
987 987 main_mod.__name__ = modname
988 988
989 989 main_mod.__file__ = filename
990 990 # It seems pydoc (and perhaps others) needs any module instance to
991 991 # implement a __nonzero__ method
992 992 main_mod.__nonzero__ = lambda : True
993 993
994 994 return main_mod
995 995
996 996 def clear_main_mod_cache(self):
997 997 """Clear the cache of main modules.
998 998
999 999 Mainly for use by utilities like %reset.
1000 1000
1001 1001 Examples
1002 1002 --------
1003 1003 In [15]: import IPython
1004 1004
1005 1005 In [16]: m = _ip.new_main_mod(IPython.__file__, 'IPython')
1006 1006
1007 1007 In [17]: len(_ip._main_mod_cache) > 0
1008 1008 Out[17]: True
1009 1009
1010 1010 In [18]: _ip.clear_main_mod_cache()
1011 1011
1012 1012 In [19]: len(_ip._main_mod_cache) == 0
1013 1013 Out[19]: True
1014 1014 """
1015 1015 self._main_mod_cache.clear()
1016 1016
1017 1017 #-------------------------------------------------------------------------
1018 1018 # Things related to debugging
1019 1019 #-------------------------------------------------------------------------
1020 1020
1021 1021 def init_pdb(self):
1022 1022 # Set calling of pdb on exceptions
1023 1023 # self.call_pdb is a property
1024 1024 self.call_pdb = self.pdb
1025 1025
1026 1026 def _get_call_pdb(self):
1027 1027 return self._call_pdb
1028 1028
1029 1029 def _set_call_pdb(self,val):
1030 1030
1031 1031 if val not in (0,1,False,True):
1032 1032 raise ValueError('new call_pdb value must be boolean')
1033 1033
1034 1034 # store value in instance
1035 1035 self._call_pdb = val
1036 1036
1037 1037 # notify the actual exception handlers
1038 1038 self.InteractiveTB.call_pdb = val
1039 1039
1040 1040 call_pdb = property(_get_call_pdb,_set_call_pdb,None,
1041 1041 'Control auto-activation of pdb at exceptions')
1042 1042
1043 1043 def debugger(self,force=False):
1044 1044 """Call the pdb debugger.
1045 1045
1046 1046 Keywords:
1047 1047
1048 1048 - force(False): by default, this routine checks the instance call_pdb
1049 1049 flag and does not actually invoke the debugger if the flag is false.
1050 1050 The 'force' option forces the debugger to activate even if the flag
1051 1051 is false.
1052 1052 """
1053 1053
1054 1054 if not (force or self.call_pdb):
1055 1055 return
1056 1056
1057 1057 if not hasattr(sys,'last_traceback'):
1058 1058 error('No traceback has been produced, nothing to debug.')
1059 1059 return
1060 1060
1061 1061 self.InteractiveTB.debugger(force=True)
1062 1062
1063 1063 #-------------------------------------------------------------------------
1064 1064 # Things related to IPython's various namespaces
1065 1065 #-------------------------------------------------------------------------
1066 1066 default_user_namespaces = True
1067 1067
1068 1068 def init_create_namespaces(self, user_module=None, user_ns=None):
1069 1069 # Create the namespace where the user will operate. user_ns is
1070 1070 # normally the only one used, and it is passed to the exec calls as
1071 1071 # the locals argument. But we do carry a user_global_ns namespace
1072 1072 # given as the exec 'globals' argument, This is useful in embedding
1073 1073 # situations where the ipython shell opens in a context where the
1074 1074 # distinction between locals and globals is meaningful. For
1075 1075 # non-embedded contexts, it is just the same object as the user_ns dict.
1076 1076
1077 1077 # FIXME. For some strange reason, __builtins__ is showing up at user
1078 1078 # level as a dict instead of a module. This is a manual fix, but I
1079 1079 # should really track down where the problem is coming from. Alex
1080 1080 # Schmolck reported this problem first.
1081 1081
1082 1082 # A useful post by Alex Martelli on this topic:
1083 1083 # Re: inconsistent value from __builtins__
1084 1084 # Von: Alex Martelli <aleaxit@yahoo.com>
1085 1085 # Datum: Freitag 01 Oktober 2004 04:45:34 nachmittags/abends
1086 1086 # Gruppen: comp.lang.python
1087 1087
1088 1088 # Michael Hohn <hohn@hooknose.lbl.gov> wrote:
1089 1089 # > >>> print type(builtin_check.get_global_binding('__builtins__'))
1090 1090 # > <type 'dict'>
1091 1091 # > >>> print type(__builtins__)
1092 1092 # > <type 'module'>
1093 1093 # > Is this difference in return value intentional?
1094 1094
1095 1095 # Well, it's documented that '__builtins__' can be either a dictionary
1096 1096 # or a module, and it's been that way for a long time. Whether it's
1097 1097 # intentional (or sensible), I don't know. In any case, the idea is
1098 1098 # that if you need to access the built-in namespace directly, you
1099 1099 # should start with "import __builtin__" (note, no 's') which will
1100 1100 # definitely give you a module. Yeah, it's somewhat confusing:-(.
1101 1101
1102 1102 # These routines return a properly built module and dict as needed by
1103 1103 # the rest of the code, and can also be used by extension writers to
1104 1104 # generate properly initialized namespaces.
1105 1105 if (user_ns is not None) or (user_module is not None):
1106 1106 self.default_user_namespaces = False
1107 1107 self.user_module, self.user_ns = self.prepare_user_module(user_module, user_ns)
1108 1108
1109 1109 # A record of hidden variables we have added to the user namespace, so
1110 1110 # we can list later only variables defined in actual interactive use.
1111 1111 self.user_ns_hidden = {}
1112 1112
1113 1113 # Now that FakeModule produces a real module, we've run into a nasty
1114 1114 # problem: after script execution (via %run), the module where the user
1115 1115 # code ran is deleted. Now that this object is a true module (needed
1116 1116 # so doctest and other tools work correctly), the Python module
1117 1117 # teardown mechanism runs over it, and sets to None every variable
1118 1118 # present in that module. Top-level references to objects from the
1119 1119 # script survive, because the user_ns is updated with them. However,
1120 1120 # calling functions defined in the script that use other things from
1121 1121 # the script will fail, because the function's closure had references
1122 1122 # to the original objects, which are now all None. So we must protect
1123 1123 # these modules from deletion by keeping a cache.
1124 1124 #
1125 1125 # To avoid keeping stale modules around (we only need the one from the
1126 1126 # last run), we use a dict keyed with the full path to the script, so
1127 1127 # only the last version of the module is held in the cache. Note,
1128 1128 # however, that we must cache the module *namespace contents* (their
1129 1129 # __dict__). Because if we try to cache the actual modules, old ones
1130 1130 # (uncached) could be destroyed while still holding references (such as
1131 1131 # those held by GUI objects that tend to be long-lived)>
1132 1132 #
1133 1133 # The %reset command will flush this cache. See the cache_main_mod()
1134 1134 # and clear_main_mod_cache() methods for details on use.
1135 1135
1136 1136 # This is the cache used for 'main' namespaces
1137 1137 self._main_mod_cache = {}
1138 1138
1139 1139 # A table holding all the namespaces IPython deals with, so that
1140 1140 # introspection facilities can search easily.
1141 1141 self.ns_table = {'user_global':self.user_module.__dict__,
1142 1142 'user_local':self.user_ns,
1143 1143 'builtin':builtin_mod.__dict__
1144 1144 }
1145 1145
1146 1146 @property
1147 1147 def user_global_ns(self):
1148 1148 return self.user_module.__dict__
1149 1149
1150 1150 def prepare_user_module(self, user_module=None, user_ns=None):
1151 1151 """Prepare the module and namespace in which user code will be run.
1152 1152
1153 1153 When IPython is started normally, both parameters are None: a new module
1154 1154 is created automatically, and its __dict__ used as the namespace.
1155 1155
1156 1156 If only user_module is provided, its __dict__ is used as the namespace.
1157 1157 If only user_ns is provided, a dummy module is created, and user_ns
1158 1158 becomes the global namespace. If both are provided (as they may be
1159 1159 when embedding), user_ns is the local namespace, and user_module
1160 1160 provides the global namespace.
1161 1161
1162 1162 Parameters
1163 1163 ----------
1164 1164 user_module : module, optional
1165 1165 The current user module in which IPython is being run. If None,
1166 1166 a clean module will be created.
1167 1167 user_ns : dict, optional
1168 1168 A namespace in which to run interactive commands.
1169 1169
1170 1170 Returns
1171 1171 -------
1172 1172 A tuple of user_module and user_ns, each properly initialised.
1173 1173 """
1174 1174 if user_module is None and user_ns is not None:
1175 1175 user_ns.setdefault("__name__", "__main__")
1176 1176 user_module = DummyMod()
1177 1177 user_module.__dict__ = user_ns
1178 1178
1179 1179 if user_module is None:
1180 1180 user_module = types.ModuleType("__main__",
1181 1181 doc="Automatically created module for IPython interactive environment")
1182 1182
1183 1183 # We must ensure that __builtin__ (without the final 's') is always
1184 1184 # available and pointing to the __builtin__ *module*. For more details:
1185 1185 # http://mail.python.org/pipermail/python-dev/2001-April/014068.html
1186 1186 user_module.__dict__.setdefault('__builtin__', builtin_mod)
1187 1187 user_module.__dict__.setdefault('__builtins__', builtin_mod)
1188 1188
1189 1189 if user_ns is None:
1190 1190 user_ns = user_module.__dict__
1191 1191
1192 1192 return user_module, user_ns
1193 1193
1194 1194 def init_sys_modules(self):
1195 1195 # We need to insert into sys.modules something that looks like a
1196 1196 # module but which accesses the IPython namespace, for shelve and
1197 1197 # pickle to work interactively. Normally they rely on getting
1198 1198 # everything out of __main__, but for embedding purposes each IPython
1199 1199 # instance has its own private namespace, so we can't go shoving
1200 1200 # everything into __main__.
1201 1201
1202 1202 # note, however, that we should only do this for non-embedded
1203 1203 # ipythons, which really mimic the __main__.__dict__ with their own
1204 1204 # namespace. Embedded instances, on the other hand, should not do
1205 1205 # this because they need to manage the user local/global namespaces
1206 1206 # only, but they live within a 'normal' __main__ (meaning, they
1207 1207 # shouldn't overtake the execution environment of the script they're
1208 1208 # embedded in).
1209 1209
1210 1210 # This is overridden in the InteractiveShellEmbed subclass to a no-op.
1211 1211 main_name = self.user_module.__name__
1212 1212 sys.modules[main_name] = self.user_module
1213 1213
1214 1214 def init_user_ns(self):
1215 1215 """Initialize all user-visible namespaces to their minimum defaults.
1216 1216
1217 1217 Certain history lists are also initialized here, as they effectively
1218 1218 act as user namespaces.
1219 1219
1220 1220 Notes
1221 1221 -----
1222 1222 All data structures here are only filled in, they are NOT reset by this
1223 1223 method. If they were not empty before, data will simply be added to
1224 1224 them.
1225 1225 """
1226 1226 # This function works in two parts: first we put a few things in
1227 1227 # user_ns, and we sync that contents into user_ns_hidden so that these
1228 1228 # initial variables aren't shown by %who. After the sync, we add the
1229 1229 # rest of what we *do* want the user to see with %who even on a new
1230 1230 # session (probably nothing, so they really only see their own stuff)
1231 1231
1232 1232 # The user dict must *always* have a __builtin__ reference to the
1233 1233 # Python standard __builtin__ namespace, which must be imported.
1234 1234 # This is so that certain operations in prompt evaluation can be
1235 1235 # reliably executed with builtins. Note that we can NOT use
1236 1236 # __builtins__ (note the 's'), because that can either be a dict or a
1237 1237 # module, and can even mutate at runtime, depending on the context
1238 1238 # (Python makes no guarantees on it). In contrast, __builtin__ is
1239 1239 # always a module object, though it must be explicitly imported.
1240 1240
1241 1241 # For more details:
1242 1242 # http://mail.python.org/pipermail/python-dev/2001-April/014068.html
1243 1243 ns = {}
1244 1244
1245 1245 # make global variables for user access to the histories
1246 1246 ns['_ih'] = self.history_manager.input_hist_parsed
1247 1247 ns['_oh'] = self.history_manager.output_hist
1248 1248 ns['_dh'] = self.history_manager.dir_hist
1249 1249
1250 1250 # user aliases to input and output histories. These shouldn't show up
1251 1251 # in %who, as they can have very large reprs.
1252 1252 ns['In'] = self.history_manager.input_hist_parsed
1253 1253 ns['Out'] = self.history_manager.output_hist
1254 1254
1255 1255 # Store myself as the public api!!!
1256 1256 ns['get_ipython'] = self.get_ipython
1257 1257
1258 1258 ns['exit'] = self.exiter
1259 1259 ns['quit'] = self.exiter
1260 1260
1261 1261 # Sync what we've added so far to user_ns_hidden so these aren't seen
1262 1262 # by %who
1263 1263 self.user_ns_hidden.update(ns)
1264 1264
1265 1265 # Anything put into ns now would show up in %who. Think twice before
1266 1266 # putting anything here, as we really want %who to show the user their
1267 1267 # stuff, not our variables.
1268 1268
1269 1269 # Finally, update the real user's namespace
1270 1270 self.user_ns.update(ns)
1271 1271
1272 1272 @property
1273 1273 def all_ns_refs(self):
1274 1274 """Get a list of references to all the namespace dictionaries in which
1275 1275 IPython might store a user-created object.
1276 1276
1277 1277 Note that this does not include the displayhook, which also caches
1278 1278 objects from the output."""
1279 1279 return [self.user_ns, self.user_global_ns, self.user_ns_hidden] + \
1280 1280 [m.__dict__ for m in self._main_mod_cache.values()]
1281 1281
1282 1282 def reset(self, new_session=True, aggressive=False):
1283 1283 """Clear all internal namespaces, and attempt to release references to
1284 1284 user objects.
1285 1285
1286 1286 If new_session is True, a new history session will be opened.
1287 1287 """
1288 1288 # Clear histories
1289 1289 self.history_manager.reset(new_session)
1290 1290 # Reset counter used to index all histories
1291 1291 if new_session:
1292 1292 self.execution_count = 1
1293 1293
1294 1294 # Reset last execution result
1295 1295 self.last_execution_succeeded = True
1296 1296 self.last_execution_result = None
1297 1297
1298 1298 # Flush cached output items
1299 1299 if self.displayhook.do_full_cache:
1300 1300 self.displayhook.flush()
1301 1301
1302 1302 # The main execution namespaces must be cleared very carefully,
1303 1303 # skipping the deletion of the builtin-related keys, because doing so
1304 1304 # would cause errors in many object's __del__ methods.
1305 1305 if self.user_ns is not self.user_global_ns:
1306 1306 self.user_ns.clear()
1307 1307 ns = self.user_global_ns
1308 1308 drop_keys = set(ns.keys())
1309 1309 drop_keys.discard('__builtin__')
1310 1310 drop_keys.discard('__builtins__')
1311 1311 drop_keys.discard('__name__')
1312 1312 for k in drop_keys:
1313 1313 del ns[k]
1314 1314
1315 1315 self.user_ns_hidden.clear()
1316 1316
1317 1317 # Restore the user namespaces to minimal usability
1318 1318 self.init_user_ns()
1319 1319 if aggressive and not hasattr(self, "_sys_modules_keys"):
1320 1320 print("Cannot restore sys.module, no snapshot")
1321 1321 elif aggressive:
1322 1322 print("culling sys module...")
1323 1323 current_keys = set(sys.modules.keys())
1324 1324 for k in current_keys - self._sys_modules_keys:
1325 1325 if k.startswith("multiprocessing"):
1326 1326 continue
1327 1327 del sys.modules[k]
1328 1328
1329 1329 # Restore the default and user aliases
1330 1330 self.alias_manager.clear_aliases()
1331 1331 self.alias_manager.init_aliases()
1332 1332
1333 1333 # Now define aliases that only make sense on the terminal, because they
1334 1334 # need direct access to the console in a way that we can't emulate in
1335 1335 # GUI or web frontend
1336 1336 if os.name == 'posix':
1337 1337 for cmd in ('clear', 'more', 'less', 'man'):
1338 1338 if cmd not in self.magics_manager.magics['line']:
1339 1339 self.alias_manager.soft_define_alias(cmd, cmd)
1340 1340
1341 1341 # Flush the private list of module references kept for script
1342 1342 # execution protection
1343 1343 self.clear_main_mod_cache()
1344 1344
1345 1345 def del_var(self, varname, by_name=False):
1346 1346 """Delete a variable from the various namespaces, so that, as
1347 1347 far as possible, we're not keeping any hidden references to it.
1348 1348
1349 1349 Parameters
1350 1350 ----------
1351 1351 varname : str
1352 1352 The name of the variable to delete.
1353 1353 by_name : bool
1354 1354 If True, delete variables with the given name in each
1355 1355 namespace. If False (default), find the variable in the user
1356 1356 namespace, and delete references to it.
1357 1357 """
1358 1358 if varname in ('__builtin__', '__builtins__'):
1359 1359 raise ValueError("Refusing to delete %s" % varname)
1360 1360
1361 1361 ns_refs = self.all_ns_refs
1362 1362
1363 1363 if by_name: # Delete by name
1364 1364 for ns in ns_refs:
1365 1365 try:
1366 1366 del ns[varname]
1367 1367 except KeyError:
1368 1368 pass
1369 1369 else: # Delete by object
1370 1370 try:
1371 1371 obj = self.user_ns[varname]
1372 1372 except KeyError as e:
1373 1373 raise NameError("name '%s' is not defined" % varname) from e
1374 1374 # Also check in output history
1375 1375 ns_refs.append(self.history_manager.output_hist)
1376 1376 for ns in ns_refs:
1377 1377 to_delete = [n for n, o in ns.items() if o is obj]
1378 1378 for name in to_delete:
1379 1379 del ns[name]
1380 1380
1381 1381 # Ensure it is removed from the last execution result
1382 1382 if self.last_execution_result.result is obj:
1383 1383 self.last_execution_result = None
1384 1384
1385 1385 # displayhook keeps extra references, but not in a dictionary
1386 1386 for name in ('_', '__', '___'):
1387 1387 if getattr(self.displayhook, name) is obj:
1388 1388 setattr(self.displayhook, name, None)
1389 1389
1390 1390 def reset_selective(self, regex=None):
1391 1391 """Clear selective variables from internal namespaces based on a
1392 1392 specified regular expression.
1393 1393
1394 1394 Parameters
1395 1395 ----------
1396 1396 regex : string or compiled pattern, optional
1397 1397 A regular expression pattern that will be used in searching
1398 1398 variable names in the users namespaces.
1399 1399 """
1400 1400 if regex is not None:
1401 1401 try:
1402 1402 m = re.compile(regex)
1403 1403 except TypeError as e:
1404 1404 raise TypeError('regex must be a string or compiled pattern') from e
1405 1405 # Search for keys in each namespace that match the given regex
1406 1406 # If a match is found, delete the key/value pair.
1407 1407 for ns in self.all_ns_refs:
1408 1408 for var in ns:
1409 1409 if m.search(var):
1410 1410 del ns[var]
1411 1411
1412 1412 def push(self, variables, interactive=True):
1413 1413 """Inject a group of variables into the IPython user namespace.
1414 1414
1415 1415 Parameters
1416 1416 ----------
1417 1417 variables : dict, str or list/tuple of str
1418 1418 The variables to inject into the user's namespace. If a dict, a
1419 1419 simple update is done. If a str, the string is assumed to have
1420 1420 variable names separated by spaces. A list/tuple of str can also
1421 1421 be used to give the variable names. If just the variable names are
1422 1422 give (list/tuple/str) then the variable values looked up in the
1423 1423 callers frame.
1424 1424 interactive : bool
1425 1425 If True (default), the variables will be listed with the ``who``
1426 1426 magic.
1427 1427 """
1428 1428 vdict = None
1429 1429
1430 1430 # We need a dict of name/value pairs to do namespace updates.
1431 1431 if isinstance(variables, dict):
1432 1432 vdict = variables
1433 1433 elif isinstance(variables, (str, list, tuple)):
1434 1434 if isinstance(variables, str):
1435 1435 vlist = variables.split()
1436 1436 else:
1437 1437 vlist = variables
1438 1438 vdict = {}
1439 1439 cf = sys._getframe(1)
1440 1440 for name in vlist:
1441 1441 try:
1442 1442 vdict[name] = eval(name, cf.f_globals, cf.f_locals)
1443 1443 except:
1444 1444 print('Could not get variable %s from %s' %
1445 1445 (name,cf.f_code.co_name))
1446 1446 else:
1447 1447 raise ValueError('variables must be a dict/str/list/tuple')
1448 1448
1449 1449 # Propagate variables to user namespace
1450 1450 self.user_ns.update(vdict)
1451 1451
1452 1452 # And configure interactive visibility
1453 1453 user_ns_hidden = self.user_ns_hidden
1454 1454 if interactive:
1455 1455 for name in vdict:
1456 1456 user_ns_hidden.pop(name, None)
1457 1457 else:
1458 1458 user_ns_hidden.update(vdict)
1459 1459
1460 1460 def drop_by_id(self, variables):
1461 1461 """Remove a dict of variables from the user namespace, if they are the
1462 1462 same as the values in the dictionary.
1463 1463
1464 1464 This is intended for use by extensions: variables that they've added can
1465 1465 be taken back out if they are unloaded, without removing any that the
1466 1466 user has overwritten.
1467 1467
1468 1468 Parameters
1469 1469 ----------
1470 1470 variables : dict
1471 1471 A dictionary mapping object names (as strings) to the objects.
1472 1472 """
1473 1473 for name, obj in variables.items():
1474 1474 if name in self.user_ns and self.user_ns[name] is obj:
1475 1475 del self.user_ns[name]
1476 1476 self.user_ns_hidden.pop(name, None)
1477 1477
1478 1478 #-------------------------------------------------------------------------
1479 1479 # Things related to object introspection
1480 1480 #-------------------------------------------------------------------------
1481 1481
1482 1482 def _ofind(self, oname, namespaces=None):
1483 1483 """Find an object in the available namespaces.
1484 1484
1485 1485 self._ofind(oname) -> dict with keys: found,obj,ospace,ismagic
1486 1486
1487 1487 Has special code to detect magic functions.
1488 1488 """
1489 1489 oname = oname.strip()
1490 1490 if not oname.startswith(ESC_MAGIC) and \
1491 1491 not oname.startswith(ESC_MAGIC2) and \
1492 1492 not all(a.isidentifier() for a in oname.split(".")):
1493 1493 return {'found': False}
1494 1494
1495 1495 if namespaces is None:
1496 1496 # Namespaces to search in:
1497 1497 # Put them in a list. The order is important so that we
1498 1498 # find things in the same order that Python finds them.
1499 1499 namespaces = [ ('Interactive', self.user_ns),
1500 1500 ('Interactive (global)', self.user_global_ns),
1501 1501 ('Python builtin', builtin_mod.__dict__),
1502 1502 ]
1503 1503
1504 1504 ismagic = False
1505 1505 isalias = False
1506 1506 found = False
1507 1507 ospace = None
1508 1508 parent = None
1509 1509 obj = None
1510 1510
1511 1511
1512 1512 # Look for the given name by splitting it in parts. If the head is
1513 1513 # found, then we look for all the remaining parts as members, and only
1514 1514 # declare success if we can find them all.
1515 1515 oname_parts = oname.split('.')
1516 1516 oname_head, oname_rest = oname_parts[0],oname_parts[1:]
1517 1517 for nsname,ns in namespaces:
1518 1518 try:
1519 1519 obj = ns[oname_head]
1520 1520 except KeyError:
1521 1521 continue
1522 1522 else:
1523 1523 for idx, part in enumerate(oname_rest):
1524 1524 try:
1525 1525 parent = obj
1526 1526 # The last part is looked up in a special way to avoid
1527 1527 # descriptor invocation as it may raise or have side
1528 1528 # effects.
1529 1529 if idx == len(oname_rest) - 1:
1530 1530 obj = self._getattr_property(obj, part)
1531 1531 else:
1532 1532 obj = getattr(obj, part)
1533 1533 except:
1534 1534 # Blanket except b/c some badly implemented objects
1535 1535 # allow __getattr__ to raise exceptions other than
1536 1536 # AttributeError, which then crashes IPython.
1537 1537 break
1538 1538 else:
1539 1539 # If we finish the for loop (no break), we got all members
1540 1540 found = True
1541 1541 ospace = nsname
1542 1542 break # namespace loop
1543 1543
1544 1544 # Try to see if it's magic
1545 1545 if not found:
1546 1546 obj = None
1547 1547 if oname.startswith(ESC_MAGIC2):
1548 1548 oname = oname.lstrip(ESC_MAGIC2)
1549 1549 obj = self.find_cell_magic(oname)
1550 1550 elif oname.startswith(ESC_MAGIC):
1551 1551 oname = oname.lstrip(ESC_MAGIC)
1552 1552 obj = self.find_line_magic(oname)
1553 1553 else:
1554 1554 # search without prefix, so run? will find %run?
1555 1555 obj = self.find_line_magic(oname)
1556 1556 if obj is None:
1557 1557 obj = self.find_cell_magic(oname)
1558 1558 if obj is not None:
1559 1559 found = True
1560 1560 ospace = 'IPython internal'
1561 1561 ismagic = True
1562 1562 isalias = isinstance(obj, Alias)
1563 1563
1564 1564 # Last try: special-case some literals like '', [], {}, etc:
1565 1565 if not found and oname_head in ["''",'""','[]','{}','()']:
1566 1566 obj = eval(oname_head)
1567 1567 found = True
1568 1568 ospace = 'Interactive'
1569 1569
1570 1570 return {
1571 1571 'obj':obj,
1572 1572 'found':found,
1573 1573 'parent':parent,
1574 1574 'ismagic':ismagic,
1575 1575 'isalias':isalias,
1576 1576 'namespace':ospace
1577 1577 }
1578 1578
1579 1579 @staticmethod
1580 1580 def _getattr_property(obj, attrname):
1581 1581 """Property-aware getattr to use in object finding.
1582 1582
1583 1583 If attrname represents a property, return it unevaluated (in case it has
1584 1584 side effects or raises an error.
1585 1585
1586 1586 """
1587 1587 if not isinstance(obj, type):
1588 1588 try:
1589 1589 # `getattr(type(obj), attrname)` is not guaranteed to return
1590 1590 # `obj`, but does so for property:
1591 1591 #
1592 1592 # property.__get__(self, None, cls) -> self
1593 1593 #
1594 1594 # The universal alternative is to traverse the mro manually
1595 1595 # searching for attrname in class dicts.
1596 1596 attr = getattr(type(obj), attrname)
1597 1597 except AttributeError:
1598 1598 pass
1599 1599 else:
1600 1600 # This relies on the fact that data descriptors (with both
1601 1601 # __get__ & __set__ magic methods) take precedence over
1602 1602 # instance-level attributes:
1603 1603 #
1604 1604 # class A(object):
1605 1605 # @property
1606 1606 # def foobar(self): return 123
1607 1607 # a = A()
1608 1608 # a.__dict__['foobar'] = 345
1609 1609 # a.foobar # == 123
1610 1610 #
1611 1611 # So, a property may be returned right away.
1612 1612 if isinstance(attr, property):
1613 1613 return attr
1614 1614
1615 1615 # Nothing helped, fall back.
1616 1616 return getattr(obj, attrname)
1617 1617
1618 1618 def _object_find(self, oname, namespaces=None):
1619 1619 """Find an object and return a struct with info about it."""
1620 1620 return Struct(self._ofind(oname, namespaces))
1621 1621
1622 1622 def _inspect(self, meth, oname, namespaces=None, **kw):
1623 1623 """Generic interface to the inspector system.
1624 1624
1625 1625 This function is meant to be called by pdef, pdoc & friends.
1626 1626 """
1627 1627 info = self._object_find(oname, namespaces)
1628 1628 docformat = (
1629 1629 sphinxify(self.object_inspect(oname)) if self.sphinxify_docstring else None
1630 1630 )
1631 1631 if info.found:
1632 1632 pmethod = getattr(self.inspector, meth)
1633 1633 # TODO: only apply format_screen to the plain/text repr of the mime
1634 1634 # bundle.
1635 1635 formatter = format_screen if info.ismagic else docformat
1636 1636 if meth == 'pdoc':
1637 1637 pmethod(info.obj, oname, formatter)
1638 1638 elif meth == 'pinfo':
1639 1639 pmethod(
1640 1640 info.obj,
1641 1641 oname,
1642 1642 formatter,
1643 1643 info,
1644 1644 enable_html_pager=self.enable_html_pager,
1645 1645 **kw,
1646 1646 )
1647 1647 else:
1648 1648 pmethod(info.obj, oname)
1649 1649 else:
1650 1650 print('Object `%s` not found.' % oname)
1651 1651 return 'not found' # so callers can take other action
1652 1652
1653 1653 def object_inspect(self, oname, detail_level=0):
1654 1654 """Get object info about oname"""
1655 1655 with self.builtin_trap:
1656 1656 info = self._object_find(oname)
1657 1657 if info.found:
1658 1658 return self.inspector.info(info.obj, oname, info=info,
1659 1659 detail_level=detail_level
1660 1660 )
1661 1661 else:
1662 1662 return oinspect.object_info(name=oname, found=False)
1663 1663
1664 1664 def object_inspect_text(self, oname, detail_level=0):
1665 1665 """Get object info as formatted text"""
1666 1666 return self.object_inspect_mime(oname, detail_level)['text/plain']
1667 1667
1668 1668 def object_inspect_mime(self, oname, detail_level=0, omit_sections=()):
1669 1669 """Get object info as a mimebundle of formatted representations.
1670 1670
1671 1671 A mimebundle is a dictionary, keyed by mime-type.
1672 1672 It must always have the key `'text/plain'`.
1673 1673 """
1674 1674 with self.builtin_trap:
1675 1675 info = self._object_find(oname)
1676 1676 if info.found:
1677 1677 docformat = (
1678 1678 sphinxify(self.object_inspect(oname))
1679 1679 if self.sphinxify_docstring
1680 1680 else None
1681 1681 )
1682 1682 return self.inspector._get_info(
1683 1683 info.obj,
1684 1684 oname,
1685 1685 info=info,
1686 1686 detail_level=detail_level,
1687 1687 formatter=docformat,
1688 1688 omit_sections=omit_sections,
1689 1689 )
1690 1690 else:
1691 1691 raise KeyError(oname)
1692 1692
1693 1693 #-------------------------------------------------------------------------
1694 1694 # Things related to history management
1695 1695 #-------------------------------------------------------------------------
1696 1696
1697 1697 def init_history(self):
1698 1698 """Sets up the command history, and starts regular autosaves."""
1699 1699 self.history_manager = HistoryManager(shell=self, parent=self)
1700 1700 self.configurables.append(self.history_manager)
1701 1701
1702 1702 #-------------------------------------------------------------------------
1703 1703 # Things related to exception handling and tracebacks (not debugging)
1704 1704 #-------------------------------------------------------------------------
1705 1705
1706 1706 debugger_cls = InterruptiblePdb
1707 1707
1708 1708 def init_traceback_handlers(self, custom_exceptions):
1709 1709 # Syntax error handler.
1710 1710 self.SyntaxTB = ultratb.SyntaxTB(color_scheme='NoColor', parent=self)
1711 1711
1712 1712 # The interactive one is initialized with an offset, meaning we always
1713 1713 # want to remove the topmost item in the traceback, which is our own
1714 1714 # internal code. Valid modes: ['Plain','Context','Verbose','Minimal']
1715 1715 self.InteractiveTB = ultratb.AutoFormattedTB(mode = 'Plain',
1716 1716 color_scheme='NoColor',
1717 1717 tb_offset = 1,
1718 1718 check_cache=check_linecache_ipython,
1719 1719 debugger_cls=self.debugger_cls, parent=self)
1720 1720
1721 1721 # The instance will store a pointer to the system-wide exception hook,
1722 1722 # so that runtime code (such as magics) can access it. This is because
1723 1723 # during the read-eval loop, it may get temporarily overwritten.
1724 1724 self.sys_excepthook = sys.excepthook
1725 1725
1726 1726 # and add any custom exception handlers the user may have specified
1727 1727 self.set_custom_exc(*custom_exceptions)
1728 1728
1729 1729 # Set the exception mode
1730 1730 self.InteractiveTB.set_mode(mode=self.xmode)
1731 1731
1732 1732 def set_custom_exc(self, exc_tuple, handler):
1733 1733 """set_custom_exc(exc_tuple, handler)
1734 1734
1735 1735 Set a custom exception handler, which will be called if any of the
1736 1736 exceptions in exc_tuple occur in the mainloop (specifically, in the
1737 1737 run_code() method).
1738 1738
1739 1739 Parameters
1740 1740 ----------
1741 1741 exc_tuple : tuple of exception classes
1742 1742 A *tuple* of exception classes, for which to call the defined
1743 1743 handler. It is very important that you use a tuple, and NOT A
1744 1744 LIST here, because of the way Python's except statement works. If
1745 1745 you only want to trap a single exception, use a singleton tuple::
1746 1746
1747 1747 exc_tuple == (MyCustomException,)
1748 1748
1749 1749 handler : callable
1750 1750 handler must have the following signature::
1751 1751
1752 1752 def my_handler(self, etype, value, tb, tb_offset=None):
1753 1753 ...
1754 1754 return structured_traceback
1755 1755
1756 1756 Your handler must return a structured traceback (a list of strings),
1757 1757 or None.
1758 1758
1759 1759 This will be made into an instance method (via types.MethodType)
1760 1760 of IPython itself, and it will be called if any of the exceptions
1761 1761 listed in the exc_tuple are caught. If the handler is None, an
1762 1762 internal basic one is used, which just prints basic info.
1763 1763
1764 1764 To protect IPython from crashes, if your handler ever raises an
1765 1765 exception or returns an invalid result, it will be immediately
1766 1766 disabled.
1767 1767
1768 1768 Notes
1769 1769 -----
1770 1770 WARNING: by putting in your own exception handler into IPython's main
1771 1771 execution loop, you run a very good chance of nasty crashes. This
1772 1772 facility should only be used if you really know what you are doing.
1773 1773 """
1774 1774
1775 1775 if not isinstance(exc_tuple, tuple):
1776 1776 raise TypeError("The custom exceptions must be given as a tuple.")
1777 1777
1778 1778 def dummy_handler(self, etype, value, tb, tb_offset=None):
1779 1779 print('*** Simple custom exception handler ***')
1780 1780 print('Exception type :', etype)
1781 1781 print('Exception value:', value)
1782 1782 print('Traceback :', tb)
1783 1783
1784 1784 def validate_stb(stb):
1785 1785 """validate structured traceback return type
1786 1786
1787 1787 return type of CustomTB *should* be a list of strings, but allow
1788 1788 single strings or None, which are harmless.
1789 1789
1790 1790 This function will *always* return a list of strings,
1791 1791 and will raise a TypeError if stb is inappropriate.
1792 1792 """
1793 1793 msg = "CustomTB must return list of strings, not %r" % stb
1794 1794 if stb is None:
1795 1795 return []
1796 1796 elif isinstance(stb, str):
1797 1797 return [stb]
1798 1798 elif not isinstance(stb, list):
1799 1799 raise TypeError(msg)
1800 1800 # it's a list
1801 1801 for line in stb:
1802 1802 # check every element
1803 1803 if not isinstance(line, str):
1804 1804 raise TypeError(msg)
1805 1805 return stb
1806 1806
1807 1807 if handler is None:
1808 1808 wrapped = dummy_handler
1809 1809 else:
1810 1810 def wrapped(self,etype,value,tb,tb_offset=None):
1811 1811 """wrap CustomTB handler, to protect IPython from user code
1812 1812
1813 1813 This makes it harder (but not impossible) for custom exception
1814 1814 handlers to crash IPython.
1815 1815 """
1816 1816 try:
1817 1817 stb = handler(self,etype,value,tb,tb_offset=tb_offset)
1818 1818 return validate_stb(stb)
1819 1819 except:
1820 1820 # clear custom handler immediately
1821 1821 self.set_custom_exc((), None)
1822 1822 print("Custom TB Handler failed, unregistering", file=sys.stderr)
1823 1823 # show the exception in handler first
1824 1824 stb = self.InteractiveTB.structured_traceback(*sys.exc_info())
1825 1825 print(self.InteractiveTB.stb2text(stb))
1826 1826 print("The original exception:")
1827 1827 stb = self.InteractiveTB.structured_traceback(
1828 1828 (etype,value,tb), tb_offset=tb_offset
1829 1829 )
1830 1830 return stb
1831 1831
1832 1832 self.CustomTB = types.MethodType(wrapped,self)
1833 1833 self.custom_exceptions = exc_tuple
1834 1834
1835 1835 def excepthook(self, etype, value, tb):
1836 1836 """One more defense for GUI apps that call sys.excepthook.
1837 1837
1838 1838 GUI frameworks like wxPython trap exceptions and call
1839 1839 sys.excepthook themselves. I guess this is a feature that
1840 1840 enables them to keep running after exceptions that would
1841 1841 otherwise kill their mainloop. This is a bother for IPython
1842 1842 which expects to catch all of the program exceptions with a try:
1843 1843 except: statement.
1844 1844
1845 1845 Normally, IPython sets sys.excepthook to a CrashHandler instance, so if
1846 1846 any app directly invokes sys.excepthook, it will look to the user like
1847 1847 IPython crashed. In order to work around this, we can disable the
1848 1848 CrashHandler and replace it with this excepthook instead, which prints a
1849 1849 regular traceback using our InteractiveTB. In this fashion, apps which
1850 1850 call sys.excepthook will generate a regular-looking exception from
1851 1851 IPython, and the CrashHandler will only be triggered by real IPython
1852 1852 crashes.
1853 1853
1854 1854 This hook should be used sparingly, only in places which are not likely
1855 1855 to be true IPython errors.
1856 1856 """
1857 1857 self.showtraceback((etype, value, tb), tb_offset=0)
1858 1858
1859 1859 def _get_exc_info(self, exc_tuple=None):
1860 1860 """get exc_info from a given tuple, sys.exc_info() or sys.last_type etc.
1861 1861
1862 1862 Ensures sys.last_type,value,traceback hold the exc_info we found,
1863 1863 from whichever source.
1864 1864
1865 1865 raises ValueError if none of these contain any information
1866 1866 """
1867 1867 if exc_tuple is None:
1868 1868 etype, value, tb = sys.exc_info()
1869 1869 else:
1870 1870 etype, value, tb = exc_tuple
1871 1871
1872 1872 if etype is None:
1873 1873 if hasattr(sys, 'last_type'):
1874 1874 etype, value, tb = sys.last_type, sys.last_value, \
1875 1875 sys.last_traceback
1876 1876
1877 1877 if etype is None:
1878 1878 raise ValueError("No exception to find")
1879 1879
1880 1880 # Now store the exception info in sys.last_type etc.
1881 1881 # WARNING: these variables are somewhat deprecated and not
1882 1882 # necessarily safe to use in a threaded environment, but tools
1883 1883 # like pdb depend on their existence, so let's set them. If we
1884 1884 # find problems in the field, we'll need to revisit their use.
1885 1885 sys.last_type = etype
1886 1886 sys.last_value = value
1887 1887 sys.last_traceback = tb
1888 1888
1889 1889 return etype, value, tb
1890 1890
1891 1891 def show_usage_error(self, exc):
1892 1892 """Show a short message for UsageErrors
1893 1893
1894 1894 These are special exceptions that shouldn't show a traceback.
1895 1895 """
1896 1896 print("UsageError: %s" % exc, file=sys.stderr)
1897 1897
1898 1898 def get_exception_only(self, exc_tuple=None):
1899 1899 """
1900 1900 Return as a string (ending with a newline) the exception that
1901 1901 just occurred, without any traceback.
1902 1902 """
1903 1903 etype, value, tb = self._get_exc_info(exc_tuple)
1904 1904 msg = traceback.format_exception_only(etype, value)
1905 1905 return ''.join(msg)
1906 1906
1907 1907 def showtraceback(self, exc_tuple=None, filename=None, tb_offset=None,
1908 1908 exception_only=False, running_compiled_code=False):
1909 1909 """Display the exception that just occurred.
1910 1910
1911 1911 If nothing is known about the exception, this is the method which
1912 1912 should be used throughout the code for presenting user tracebacks,
1913 1913 rather than directly invoking the InteractiveTB object.
1914 1914
1915 1915 A specific showsyntaxerror() also exists, but this method can take
1916 1916 care of calling it if needed, so unless you are explicitly catching a
1917 1917 SyntaxError exception, don't try to analyze the stack manually and
1918 1918 simply call this method."""
1919 1919
1920 1920 try:
1921 1921 try:
1922 1922 etype, value, tb = self._get_exc_info(exc_tuple)
1923 1923 except ValueError:
1924 1924 print('No traceback available to show.', file=sys.stderr)
1925 1925 return
1926 1926
1927 1927 if issubclass(etype, SyntaxError):
1928 1928 # Though this won't be called by syntax errors in the input
1929 1929 # line, there may be SyntaxError cases with imported code.
1930 1930 self.showsyntaxerror(filename, running_compiled_code)
1931 1931 elif etype is UsageError:
1932 1932 self.show_usage_error(value)
1933 1933 else:
1934 1934 if exception_only:
1935 1935 stb = ['An exception has occurred, use %tb to see '
1936 1936 'the full traceback.\n']
1937 1937 stb.extend(self.InteractiveTB.get_exception_only(etype,
1938 1938 value))
1939 1939 else:
1940 1940 try:
1941 1941 # Exception classes can customise their traceback - we
1942 1942 # use this in IPython.parallel for exceptions occurring
1943 1943 # in the engines. This should return a list of strings.
1944 1944 stb = value._render_traceback_()
1945 1945 except Exception:
1946 1946 stb = self.InteractiveTB.structured_traceback(etype,
1947 1947 value, tb, tb_offset=tb_offset)
1948 1948
1949 1949 self._showtraceback(etype, value, stb)
1950 1950 if self.call_pdb:
1951 1951 # drop into debugger
1952 1952 self.debugger(force=True)
1953 1953 return
1954 1954
1955 1955 # Actually show the traceback
1956 1956 self._showtraceback(etype, value, stb)
1957 1957
1958 1958 except KeyboardInterrupt:
1959 1959 print('\n' + self.get_exception_only(), file=sys.stderr)
1960 1960
1961 1961 def _showtraceback(self, etype, evalue, stb: str):
1962 1962 """Actually show a traceback.
1963 1963
1964 1964 Subclasses may override this method to put the traceback on a different
1965 1965 place, like a side channel.
1966 1966 """
1967 1967 val = self.InteractiveTB.stb2text(stb)
1968 1968 try:
1969 1969 print(val)
1970 1970 except UnicodeEncodeError:
1971 1971 print(val.encode("utf-8", "backslashreplace").decode())
1972 1972
1973 1973 def showsyntaxerror(self, filename=None, running_compiled_code=False):
1974 1974 """Display the syntax error that just occurred.
1975 1975
1976 1976 This doesn't display a stack trace because there isn't one.
1977 1977
1978 1978 If a filename is given, it is stuffed in the exception instead
1979 1979 of what was there before (because Python's parser always uses
1980 1980 "<string>" when reading from a string).
1981 1981
1982 1982 If the syntax error occurred when running a compiled code (i.e. running_compile_code=True),
1983 1983 longer stack trace will be displayed.
1984 1984 """
1985 1985 etype, value, last_traceback = self._get_exc_info()
1986 1986
1987 1987 if filename and issubclass(etype, SyntaxError):
1988 1988 try:
1989 1989 value.filename = filename
1990 1990 except:
1991 1991 # Not the format we expect; leave it alone
1992 1992 pass
1993 1993
1994 1994 # If the error occurred when executing compiled code, we should provide full stacktrace.
1995 1995 elist = traceback.extract_tb(last_traceback) if running_compiled_code else []
1996 1996 stb = self.SyntaxTB.structured_traceback(etype, value, elist)
1997 1997 self._showtraceback(etype, value, stb)
1998 1998
1999 1999 # This is overridden in TerminalInteractiveShell to show a message about
2000 2000 # the %paste magic.
2001 2001 def showindentationerror(self):
2002 2002 """Called by _run_cell when there's an IndentationError in code entered
2003 2003 at the prompt.
2004 2004
2005 2005 This is overridden in TerminalInteractiveShell to show a message about
2006 2006 the %paste magic."""
2007 2007 self.showsyntaxerror()
2008 2008
2009 2009 @skip_doctest
2010 2010 def set_next_input(self, s, replace=False):
2011 2011 """ Sets the 'default' input string for the next command line.
2012 2012
2013 2013 Example::
2014 2014
2015 2015 In [1]: _ip.set_next_input("Hello Word")
2016 2016 In [2]: Hello Word_ # cursor is here
2017 2017 """
2018 2018 self.rl_next_input = s
2019 2019
2020 2020 def _indent_current_str(self):
2021 2021 """return the current level of indentation as a string"""
2022 2022 return self.input_splitter.get_indent_spaces() * ' '
2023 2023
2024 2024 #-------------------------------------------------------------------------
2025 2025 # Things related to text completion
2026 2026 #-------------------------------------------------------------------------
2027 2027
2028 2028 def init_completer(self):
2029 2029 """Initialize the completion machinery.
2030 2030
2031 2031 This creates completion machinery that can be used by client code,
2032 2032 either interactively in-process (typically triggered by the readline
2033 2033 library), programmatically (such as in test suites) or out-of-process
2034 2034 (typically over the network by remote frontends).
2035 2035 """
2036 2036 from IPython.core.completer import IPCompleter
2037 2037 from IPython.core.completerlib import (module_completer,
2038 2038 magic_run_completer, cd_completer, reset_completer)
2039 2039
2040 2040 self.Completer = IPCompleter(shell=self,
2041 2041 namespace=self.user_ns,
2042 2042 global_namespace=self.user_global_ns,
2043 2043 parent=self,
2044 2044 )
2045 2045 self.configurables.append(self.Completer)
2046 2046
2047 2047 # Add custom completers to the basic ones built into IPCompleter
2048 2048 sdisp = self.strdispatchers.get('complete_command', StrDispatch())
2049 2049 self.strdispatchers['complete_command'] = sdisp
2050 2050 self.Completer.custom_completers = sdisp
2051 2051
2052 2052 self.set_hook('complete_command', module_completer, str_key = 'import')
2053 2053 self.set_hook('complete_command', module_completer, str_key = 'from')
2054 2054 self.set_hook('complete_command', module_completer, str_key = '%aimport')
2055 2055 self.set_hook('complete_command', magic_run_completer, str_key = '%run')
2056 2056 self.set_hook('complete_command', cd_completer, str_key = '%cd')
2057 2057 self.set_hook('complete_command', reset_completer, str_key = '%reset')
2058 2058
2059 2059 @skip_doctest
2060 2060 def complete(self, text, line=None, cursor_pos=None):
2061 2061 """Return the completed text and a list of completions.
2062 2062
2063 2063 Parameters
2064 2064 ----------
2065 2065 text : string
2066 2066 A string of text to be completed on. It can be given as empty and
2067 2067 instead a line/position pair are given. In this case, the
2068 2068 completer itself will split the line like readline does.
2069 2069 line : string, optional
2070 2070 The complete line that text is part of.
2071 2071 cursor_pos : int, optional
2072 2072 The position of the cursor on the input line.
2073 2073
2074 2074 Returns
2075 2075 -------
2076 2076 text : string
2077 2077 The actual text that was completed.
2078 2078 matches : list
2079 2079 A sorted list with all possible completions.
2080 2080
2081 2081 Notes
2082 2082 -----
2083 2083 The optional arguments allow the completion to take more context into
2084 2084 account, and are part of the low-level completion API.
2085 2085
2086 2086 This is a wrapper around the completion mechanism, similar to what
2087 2087 readline does at the command line when the TAB key is hit. By
2088 2088 exposing it as a method, it can be used by other non-readline
2089 2089 environments (such as GUIs) for text completion.
2090 2090
2091 2091 Examples
2092 2092 --------
2093 2093 In [1]: x = 'hello'
2094 2094
2095 2095 In [2]: _ip.complete('x.l')
2096 2096 Out[2]: ('x.l', ['x.ljust', 'x.lower', 'x.lstrip'])
2097 2097 """
2098 2098
2099 2099 # Inject names into __builtin__ so we can complete on the added names.
2100 2100 with self.builtin_trap:
2101 2101 return self.Completer.complete(text, line, cursor_pos)
2102 2102
2103 2103 def set_custom_completer(self, completer, pos=0) -> None:
2104 2104 """Adds a new custom completer function.
2105 2105
2106 2106 The position argument (defaults to 0) is the index in the completers
2107 2107 list where you want the completer to be inserted.
2108 2108
2109 2109 `completer` should have the following signature::
2110 2110
2111 2111 def completion(self: Completer, text: string) -> List[str]:
2112 2112 raise NotImplementedError
2113 2113
2114 2114 It will be bound to the current Completer instance and pass some text
2115 2115 and return a list with current completions to suggest to the user.
2116 2116 """
2117 2117
2118 2118 newcomp = types.MethodType(completer, self.Completer)
2119 2119 self.Completer.custom_matchers.insert(pos,newcomp)
2120 2120
2121 2121 def set_completer_frame(self, frame=None):
2122 2122 """Set the frame of the completer."""
2123 2123 if frame:
2124 2124 self.Completer.namespace = frame.f_locals
2125 2125 self.Completer.global_namespace = frame.f_globals
2126 2126 else:
2127 2127 self.Completer.namespace = self.user_ns
2128 2128 self.Completer.global_namespace = self.user_global_ns
2129 2129
2130 2130 #-------------------------------------------------------------------------
2131 2131 # Things related to magics
2132 2132 #-------------------------------------------------------------------------
2133 2133
2134 2134 def init_magics(self):
2135 2135 from IPython.core import magics as m
2136 2136 self.magics_manager = magic.MagicsManager(shell=self,
2137 2137 parent=self,
2138 2138 user_magics=m.UserMagics(self))
2139 2139 self.configurables.append(self.magics_manager)
2140 2140
2141 2141 # Expose as public API from the magics manager
2142 2142 self.register_magics = self.magics_manager.register
2143 2143
2144 2144 self.register_magics(m.AutoMagics, m.BasicMagics, m.CodeMagics,
2145 2145 m.ConfigMagics, m.DisplayMagics, m.ExecutionMagics,
2146 2146 m.ExtensionMagics, m.HistoryMagics, m.LoggingMagics,
2147 2147 m.NamespaceMagics, m.OSMagics, m.PackagingMagics,
2148 2148 m.PylabMagics, m.ScriptMagics,
2149 2149 )
2150 2150 self.register_magics(m.AsyncMagics)
2151 2151
2152 2152 # Register Magic Aliases
2153 2153 mman = self.magics_manager
2154 2154 # FIXME: magic aliases should be defined by the Magics classes
2155 2155 # or in MagicsManager, not here
2156 2156 mman.register_alias('ed', 'edit')
2157 2157 mman.register_alias('hist', 'history')
2158 2158 mman.register_alias('rep', 'recall')
2159 2159 mman.register_alias('SVG', 'svg', 'cell')
2160 2160 mman.register_alias('HTML', 'html', 'cell')
2161 2161 mman.register_alias('file', 'writefile', 'cell')
2162 2162
2163 2163 # FIXME: Move the color initialization to the DisplayHook, which
2164 2164 # should be split into a prompt manager and displayhook. We probably
2165 2165 # even need a centralize colors management object.
2166 2166 self.run_line_magic('colors', self.colors)
2167 2167
2168 2168 # Defined here so that it's included in the documentation
2169 2169 @functools.wraps(magic.MagicsManager.register_function)
2170 2170 def register_magic_function(self, func, magic_kind='line', magic_name=None):
2171 2171 self.magics_manager.register_function(
2172 2172 func, magic_kind=magic_kind, magic_name=magic_name
2173 2173 )
2174 2174
2175 2175 def _find_with_lazy_load(self, /, type_, magic_name: str):
2176 2176 """
2177 2177 Try to find a magic potentially lazy-loading it.
2178 2178
2179 2179 Parameters
2180 2180 ----------
2181 2181
2182 2182 type_: "line"|"cell"
2183 2183 the type of magics we are trying to find/lazy load.
2184 2184 magic_name: str
2185 2185 The name of the magic we are trying to find/lazy load
2186 2186
2187 2187
2188 2188 Note that this may have any side effects
2189 2189 """
2190 2190 finder = {"line": self.find_line_magic, "cell": self.find_cell_magic}[type_]
2191 2191 fn = finder(magic_name)
2192 2192 if fn is not None:
2193 2193 return fn
2194 2194 lazy = self.magics_manager.lazy_magics.get(magic_name)
2195 2195 if lazy is None:
2196 2196 return None
2197 2197
2198 2198 self.run_line_magic("load_ext", lazy)
2199 2199 res = finder(magic_name)
2200 2200 return res
2201 2201
2202 2202 def run_line_magic(self, magic_name: str, line, _stack_depth=1):
2203 2203 """Execute the given line magic.
2204 2204
2205 2205 Parameters
2206 2206 ----------
2207 2207 magic_name : str
2208 2208 Name of the desired magic function, without '%' prefix.
2209 2209 line : str
2210 2210 The rest of the input line as a single string.
2211 2211 _stack_depth : int
2212 2212 If run_line_magic() is called from magic() then _stack_depth=2.
2213 2213 This is added to ensure backward compatibility for use of 'get_ipython().magic()'
2214 2214 """
2215 2215 fn = self._find_with_lazy_load("line", magic_name)
2216 2216 if fn is None:
2217 2217 lazy = self.magics_manager.lazy_magics.get(magic_name)
2218 2218 if lazy:
2219 2219 self.run_line_magic("load_ext", lazy)
2220 2220 fn = self.find_line_magic(magic_name)
2221 2221 if fn is None:
2222 2222 cm = self.find_cell_magic(magic_name)
2223 2223 etpl = "Line magic function `%%%s` not found%s."
2224 2224 extra = '' if cm is None else (' (But cell magic `%%%%%s` exists, '
2225 2225 'did you mean that instead?)' % magic_name )
2226 2226 raise UsageError(etpl % (magic_name, extra))
2227 2227 else:
2228 2228 # Note: this is the distance in the stack to the user's frame.
2229 2229 # This will need to be updated if the internal calling logic gets
2230 2230 # refactored, or else we'll be expanding the wrong variables.
2231 2231
2232 2232 # Determine stack_depth depending on where run_line_magic() has been called
2233 2233 stack_depth = _stack_depth
2234 2234 if getattr(fn, magic.MAGIC_NO_VAR_EXPAND_ATTR, False):
2235 2235 # magic has opted out of var_expand
2236 2236 magic_arg_s = line
2237 2237 else:
2238 2238 magic_arg_s = self.var_expand(line, stack_depth)
2239 2239 # Put magic args in a list so we can call with f(*a) syntax
2240 2240 args = [magic_arg_s]
2241 2241 kwargs = {}
2242 2242 # Grab local namespace if we need it:
2243 2243 if getattr(fn, "needs_local_scope", False):
2244 2244 kwargs['local_ns'] = self.get_local_scope(stack_depth)
2245 2245 with self.builtin_trap:
2246 2246 result = fn(*args, **kwargs)
2247 2247 return result
2248 2248
2249 2249 def get_local_scope(self, stack_depth):
2250 2250 """Get local scope at given stack depth.
2251 2251
2252 2252 Parameters
2253 2253 ----------
2254 2254 stack_depth : int
2255 2255 Depth relative to calling frame
2256 2256 """
2257 2257 return sys._getframe(stack_depth + 1).f_locals
2258 2258
2259 2259 def run_cell_magic(self, magic_name, line, cell):
2260 2260 """Execute the given cell magic.
2261 2261
2262 2262 Parameters
2263 2263 ----------
2264 2264 magic_name : str
2265 2265 Name of the desired magic function, without '%' prefix.
2266 2266 line : str
2267 2267 The rest of the first input line as a single string.
2268 2268 cell : str
2269 2269 The body of the cell as a (possibly multiline) string.
2270 2270 """
2271 2271 fn = self._find_with_lazy_load("cell", magic_name)
2272 2272 if fn is None:
2273 2273 lm = self.find_line_magic(magic_name)
2274 2274 etpl = "Cell magic `%%{0}` not found{1}."
2275 2275 extra = '' if lm is None else (' (But line magic `%{0}` exists, '
2276 2276 'did you mean that instead?)'.format(magic_name))
2277 2277 raise UsageError(etpl.format(magic_name, extra))
2278 2278 elif cell == '':
2279 2279 message = '%%{0} is a cell magic, but the cell body is empty.'.format(magic_name)
2280 2280 if self.find_line_magic(magic_name) is not None:
2281 2281 message += ' Did you mean the line magic %{0} (single %)?'.format(magic_name)
2282 2282 raise UsageError(message)
2283 2283 else:
2284 2284 # Note: this is the distance in the stack to the user's frame.
2285 2285 # This will need to be updated if the internal calling logic gets
2286 2286 # refactored, or else we'll be expanding the wrong variables.
2287 2287 stack_depth = 2
2288 2288 if getattr(fn, magic.MAGIC_NO_VAR_EXPAND_ATTR, False):
2289 2289 # magic has opted out of var_expand
2290 2290 magic_arg_s = line
2291 2291 else:
2292 2292 magic_arg_s = self.var_expand(line, stack_depth)
2293 2293 kwargs = {}
2294 2294 if getattr(fn, "needs_local_scope", False):
2295 2295 kwargs['local_ns'] = self.user_ns
2296 2296
2297 2297 with self.builtin_trap:
2298 2298 args = (magic_arg_s, cell)
2299 2299 result = fn(*args, **kwargs)
2300 2300 return result
2301 2301
2302 2302 def find_line_magic(self, magic_name):
2303 2303 """Find and return a line magic by name.
2304 2304
2305 2305 Returns None if the magic isn't found."""
2306 2306 return self.magics_manager.magics['line'].get(magic_name)
2307 2307
2308 2308 def find_cell_magic(self, magic_name):
2309 2309 """Find and return a cell magic by name.
2310 2310
2311 2311 Returns None if the magic isn't found."""
2312 2312 return self.magics_manager.magics['cell'].get(magic_name)
2313 2313
2314 2314 def find_magic(self, magic_name, magic_kind='line'):
2315 2315 """Find and return a magic of the given type by name.
2316 2316
2317 2317 Returns None if the magic isn't found."""
2318 2318 return self.magics_manager.magics[magic_kind].get(magic_name)
2319 2319
2320 2320 def magic(self, arg_s):
2321 2321 """
2322 2322 DEPRECATED
2323 2323
2324 2324 Deprecated since IPython 0.13 (warning added in
2325 2325 8.1), use run_line_magic(magic_name, parameter_s).
2326 2326
2327 2327 Call a magic function by name.
2328 2328
2329 2329 Input: a string containing the name of the magic function to call and
2330 2330 any additional arguments to be passed to the magic.
2331 2331
2332 2332 magic('name -opt foo bar') is equivalent to typing at the ipython
2333 2333 prompt:
2334 2334
2335 2335 In[1]: %name -opt foo bar
2336 2336
2337 2337 To call a magic without arguments, simply use magic('name').
2338 2338
2339 2339 This provides a proper Python function to call IPython's magics in any
2340 2340 valid Python code you can type at the interpreter, including loops and
2341 2341 compound statements.
2342 2342 """
2343 2343 warnings.warn(
2344 2344 "`magic(...)` is deprecated since IPython 0.13 (warning added in "
2345 2345 "8.1), use run_line_magic(magic_name, parameter_s).",
2346 2346 DeprecationWarning,
2347 2347 stacklevel=2,
2348 2348 )
2349 2349 # TODO: should we issue a loud deprecation warning here?
2350 2350 magic_name, _, magic_arg_s = arg_s.partition(' ')
2351 2351 magic_name = magic_name.lstrip(prefilter.ESC_MAGIC)
2352 2352 return self.run_line_magic(magic_name, magic_arg_s, _stack_depth=2)
2353 2353
2354 2354 #-------------------------------------------------------------------------
2355 2355 # Things related to macros
2356 2356 #-------------------------------------------------------------------------
2357 2357
2358 2358 def define_macro(self, name, themacro):
2359 2359 """Define a new macro
2360 2360
2361 2361 Parameters
2362 2362 ----------
2363 2363 name : str
2364 2364 The name of the macro.
2365 2365 themacro : str or Macro
2366 2366 The action to do upon invoking the macro. If a string, a new
2367 2367 Macro object is created by passing the string to it.
2368 2368 """
2369 2369
2370 2370 from IPython.core import macro
2371 2371
2372 2372 if isinstance(themacro, str):
2373 2373 themacro = macro.Macro(themacro)
2374 2374 if not isinstance(themacro, macro.Macro):
2375 2375 raise ValueError('A macro must be a string or a Macro instance.')
2376 2376 self.user_ns[name] = themacro
2377 2377
2378 2378 #-------------------------------------------------------------------------
2379 2379 # Things related to the running of system commands
2380 2380 #-------------------------------------------------------------------------
2381 2381
2382 2382 def system_piped(self, cmd):
2383 2383 """Call the given cmd in a subprocess, piping stdout/err
2384 2384
2385 2385 Parameters
2386 2386 ----------
2387 2387 cmd : str
2388 2388 Command to execute (can not end in '&', as background processes are
2389 2389 not supported. Should not be a command that expects input
2390 2390 other than simple text.
2391 2391 """
2392 2392 if cmd.rstrip().endswith('&'):
2393 2393 # this is *far* from a rigorous test
2394 2394 # We do not support backgrounding processes because we either use
2395 2395 # pexpect or pipes to read from. Users can always just call
2396 2396 # os.system() or use ip.system=ip.system_raw
2397 2397 # if they really want a background process.
2398 2398 raise OSError("Background processes not supported.")
2399 2399
2400 2400 # we explicitly do NOT return the subprocess status code, because
2401 2401 # a non-None value would trigger :func:`sys.displayhook` calls.
2402 2402 # Instead, we store the exit_code in user_ns.
2403 2403 self.user_ns['_exit_code'] = system(self.var_expand(cmd, depth=1))
2404 2404
2405 2405 def system_raw(self, cmd):
2406 2406 """Call the given cmd in a subprocess using os.system on Windows or
2407 2407 subprocess.call using the system shell on other platforms.
2408 2408
2409 2409 Parameters
2410 2410 ----------
2411 2411 cmd : str
2412 2412 Command to execute.
2413 2413 """
2414 2414 cmd = self.var_expand(cmd, depth=1)
2415 2415 # warn if there is an IPython magic alternative.
2416 2416 main_cmd = cmd.split()[0]
2417 has_magic_alternatives = ("pip", "conda", "cd", "ls")
2417 has_magic_alternatives = ("pip", "conda", "cd")
2418 2418
2419 # had to check if the command was an alias expanded because of `ls`
2420 is_alias_expanded = self.alias_manager.is_alias(main_cmd) and (
2421 self.alias_manager.retrieve_alias(main_cmd).strip() == cmd.strip()
2422 )
2423
2424 if main_cmd in has_magic_alternatives and not is_alias_expanded:
2419 if main_cmd in has_magic_alternatives:
2425 2420 warnings.warn(
2426 2421 (
2427 2422 "You executed the system command !{0} which may not work "
2428 2423 "as expected. Try the IPython magic %{0} instead."
2429 2424 ).format(main_cmd)
2430 2425 )
2431 2426
2432 2427 # protect os.system from UNC paths on Windows, which it can't handle:
2433 2428 if sys.platform == 'win32':
2434 2429 from IPython.utils._process_win32 import AvoidUNCPath
2435 2430 with AvoidUNCPath() as path:
2436 2431 if path is not None:
2437 2432 cmd = '"pushd %s &&"%s' % (path, cmd)
2438 2433 try:
2439 2434 ec = os.system(cmd)
2440 2435 except KeyboardInterrupt:
2441 2436 print('\n' + self.get_exception_only(), file=sys.stderr)
2442 2437 ec = -2
2443 2438 else:
2444 2439 # For posix the result of the subprocess.call() below is an exit
2445 2440 # code, which by convention is zero for success, positive for
2446 2441 # program failure. Exit codes above 128 are reserved for signals,
2447 2442 # and the formula for converting a signal to an exit code is usually
2448 2443 # signal_number+128. To more easily differentiate between exit
2449 2444 # codes and signals, ipython uses negative numbers. For instance
2450 2445 # since control-c is signal 2 but exit code 130, ipython's
2451 2446 # _exit_code variable will read -2. Note that some shells like
2452 2447 # csh and fish don't follow sh/bash conventions for exit codes.
2453 2448 executable = os.environ.get('SHELL', None)
2454 2449 try:
2455 2450 # Use env shell instead of default /bin/sh
2456 2451 ec = subprocess.call(cmd, shell=True, executable=executable)
2457 2452 except KeyboardInterrupt:
2458 2453 # intercept control-C; a long traceback is not useful here
2459 2454 print('\n' + self.get_exception_only(), file=sys.stderr)
2460 2455 ec = 130
2461 2456 if ec > 128:
2462 2457 ec = -(ec - 128)
2463 2458
2464 2459 # We explicitly do NOT return the subprocess status code, because
2465 2460 # a non-None value would trigger :func:`sys.displayhook` calls.
2466 2461 # Instead, we store the exit_code in user_ns. Note the semantics
2467 2462 # of _exit_code: for control-c, _exit_code == -signal.SIGNIT,
2468 2463 # but raising SystemExit(_exit_code) will give status 254!
2469 2464 self.user_ns['_exit_code'] = ec
2470 2465
2471 2466 # use piped system by default, because it is better behaved
2472 2467 system = system_piped
2473 2468
2474 2469 def getoutput(self, cmd, split=True, depth=0):
2475 2470 """Get output (possibly including stderr) from a subprocess.
2476 2471
2477 2472 Parameters
2478 2473 ----------
2479 2474 cmd : str
2480 2475 Command to execute (can not end in '&', as background processes are
2481 2476 not supported.
2482 2477 split : bool, optional
2483 2478 If True, split the output into an IPython SList. Otherwise, an
2484 2479 IPython LSString is returned. These are objects similar to normal
2485 2480 lists and strings, with a few convenience attributes for easier
2486 2481 manipulation of line-based output. You can use '?' on them for
2487 2482 details.
2488 2483 depth : int, optional
2489 2484 How many frames above the caller are the local variables which should
2490 2485 be expanded in the command string? The default (0) assumes that the
2491 2486 expansion variables are in the stack frame calling this function.
2492 2487 """
2493 2488 if cmd.rstrip().endswith('&'):
2494 2489 # this is *far* from a rigorous test
2495 2490 raise OSError("Background processes not supported.")
2496 2491 out = getoutput(self.var_expand(cmd, depth=depth+1))
2497 2492 if split:
2498 2493 out = SList(out.splitlines())
2499 2494 else:
2500 2495 out = LSString(out)
2501 2496 return out
2502 2497
2503 2498 #-------------------------------------------------------------------------
2504 2499 # Things related to aliases
2505 2500 #-------------------------------------------------------------------------
2506 2501
2507 2502 def init_alias(self):
2508 2503 self.alias_manager = AliasManager(shell=self, parent=self)
2509 2504 self.configurables.append(self.alias_manager)
2510 2505
2511 2506 #-------------------------------------------------------------------------
2512 2507 # Things related to extensions
2513 2508 #-------------------------------------------------------------------------
2514 2509
2515 2510 def init_extension_manager(self):
2516 2511 self.extension_manager = ExtensionManager(shell=self, parent=self)
2517 2512 self.configurables.append(self.extension_manager)
2518 2513
2519 2514 #-------------------------------------------------------------------------
2520 2515 # Things related to payloads
2521 2516 #-------------------------------------------------------------------------
2522 2517
2523 2518 def init_payload(self):
2524 2519 self.payload_manager = PayloadManager(parent=self)
2525 2520 self.configurables.append(self.payload_manager)
2526 2521
2527 2522 #-------------------------------------------------------------------------
2528 2523 # Things related to the prefilter
2529 2524 #-------------------------------------------------------------------------
2530 2525
2531 2526 def init_prefilter(self):
2532 2527 self.prefilter_manager = PrefilterManager(shell=self, parent=self)
2533 2528 self.configurables.append(self.prefilter_manager)
2534 2529 # Ultimately this will be refactored in the new interpreter code, but
2535 2530 # for now, we should expose the main prefilter method (there's legacy
2536 2531 # code out there that may rely on this).
2537 2532 self.prefilter = self.prefilter_manager.prefilter_lines
2538 2533
2539 2534 def auto_rewrite_input(self, cmd):
2540 2535 """Print to the screen the rewritten form of the user's command.
2541 2536
2542 2537 This shows visual feedback by rewriting input lines that cause
2543 2538 automatic calling to kick in, like::
2544 2539
2545 2540 /f x
2546 2541
2547 2542 into::
2548 2543
2549 2544 ------> f(x)
2550 2545
2551 2546 after the user's input prompt. This helps the user understand that the
2552 2547 input line was transformed automatically by IPython.
2553 2548 """
2554 2549 if not self.show_rewritten_input:
2555 2550 return
2556 2551
2557 2552 # This is overridden in TerminalInteractiveShell to use fancy prompts
2558 2553 print("------> " + cmd)
2559 2554
2560 2555 #-------------------------------------------------------------------------
2561 2556 # Things related to extracting values/expressions from kernel and user_ns
2562 2557 #-------------------------------------------------------------------------
2563 2558
2564 2559 def _user_obj_error(self):
2565 2560 """return simple exception dict
2566 2561
2567 2562 for use in user_expressions
2568 2563 """
2569 2564
2570 2565 etype, evalue, tb = self._get_exc_info()
2571 2566 stb = self.InteractiveTB.get_exception_only(etype, evalue)
2572 2567
2573 2568 exc_info = {
2574 2569 "status": "error",
2575 2570 "traceback": stb,
2576 2571 "ename": etype.__name__,
2577 2572 "evalue": py3compat.safe_unicode(evalue),
2578 2573 }
2579 2574
2580 2575 return exc_info
2581 2576
2582 2577 def _format_user_obj(self, obj):
2583 2578 """format a user object to display dict
2584 2579
2585 2580 for use in user_expressions
2586 2581 """
2587 2582
2588 2583 data, md = self.display_formatter.format(obj)
2589 2584 value = {
2590 2585 'status' : 'ok',
2591 2586 'data' : data,
2592 2587 'metadata' : md,
2593 2588 }
2594 2589 return value
2595 2590
2596 2591 def user_expressions(self, expressions):
2597 2592 """Evaluate a dict of expressions in the user's namespace.
2598 2593
2599 2594 Parameters
2600 2595 ----------
2601 2596 expressions : dict
2602 2597 A dict with string keys and string values. The expression values
2603 2598 should be valid Python expressions, each of which will be evaluated
2604 2599 in the user namespace.
2605 2600
2606 2601 Returns
2607 2602 -------
2608 2603 A dict, keyed like the input expressions dict, with the rich mime-typed
2609 2604 display_data of each value.
2610 2605 """
2611 2606 out = {}
2612 2607 user_ns = self.user_ns
2613 2608 global_ns = self.user_global_ns
2614 2609
2615 2610 for key, expr in expressions.items():
2616 2611 try:
2617 2612 value = self._format_user_obj(eval(expr, global_ns, user_ns))
2618 2613 except:
2619 2614 value = self._user_obj_error()
2620 2615 out[key] = value
2621 2616 return out
2622 2617
2623 2618 #-------------------------------------------------------------------------
2624 2619 # Things related to the running of code
2625 2620 #-------------------------------------------------------------------------
2626 2621
2627 2622 def ex(self, cmd):
2628 2623 """Execute a normal python statement in user namespace."""
2629 2624 with self.builtin_trap:
2630 2625 exec(cmd, self.user_global_ns, self.user_ns)
2631 2626
2632 2627 def ev(self, expr):
2633 2628 """Evaluate python expression expr in user namespace.
2634 2629
2635 2630 Returns the result of evaluation
2636 2631 """
2637 2632 with self.builtin_trap:
2638 2633 return eval(expr, self.user_global_ns, self.user_ns)
2639 2634
2640 2635 def safe_execfile(self, fname, *where, exit_ignore=False, raise_exceptions=False, shell_futures=False):
2641 2636 """A safe version of the builtin execfile().
2642 2637
2643 2638 This version will never throw an exception, but instead print
2644 2639 helpful error messages to the screen. This only works on pure
2645 2640 Python files with the .py extension.
2646 2641
2647 2642 Parameters
2648 2643 ----------
2649 2644 fname : string
2650 2645 The name of the file to be executed.
2651 2646 *where : tuple
2652 2647 One or two namespaces, passed to execfile() as (globals,locals).
2653 2648 If only one is given, it is passed as both.
2654 2649 exit_ignore : bool (False)
2655 2650 If True, then silence SystemExit for non-zero status (it is always
2656 2651 silenced for zero status, as it is so common).
2657 2652 raise_exceptions : bool (False)
2658 2653 If True raise exceptions everywhere. Meant for testing.
2659 2654 shell_futures : bool (False)
2660 2655 If True, the code will share future statements with the interactive
2661 2656 shell. It will both be affected by previous __future__ imports, and
2662 2657 any __future__ imports in the code will affect the shell. If False,
2663 2658 __future__ imports are not shared in either direction.
2664 2659
2665 2660 """
2666 2661 fname = Path(fname).expanduser().resolve()
2667 2662
2668 2663 # Make sure we can open the file
2669 2664 try:
2670 2665 with fname.open("rb"):
2671 2666 pass
2672 2667 except:
2673 2668 warn('Could not open file <%s> for safe execution.' % fname)
2674 2669 return
2675 2670
2676 2671 # Find things also in current directory. This is needed to mimic the
2677 2672 # behavior of running a script from the system command line, where
2678 2673 # Python inserts the script's directory into sys.path
2679 2674 dname = str(fname.parent)
2680 2675
2681 2676 with prepended_to_syspath(dname), self.builtin_trap:
2682 2677 try:
2683 2678 glob, loc = (where + (None, ))[:2]
2684 2679 py3compat.execfile(
2685 2680 fname, glob, loc,
2686 2681 self.compile if shell_futures else None)
2687 2682 except SystemExit as status:
2688 2683 # If the call was made with 0 or None exit status (sys.exit(0)
2689 2684 # or sys.exit() ), don't bother showing a traceback, as both of
2690 2685 # these are considered normal by the OS:
2691 2686 # > python -c'import sys;sys.exit(0)'; echo $?
2692 2687 # 0
2693 2688 # > python -c'import sys;sys.exit()'; echo $?
2694 2689 # 0
2695 2690 # For other exit status, we show the exception unless
2696 2691 # explicitly silenced, but only in short form.
2697 2692 if status.code:
2698 2693 if raise_exceptions:
2699 2694 raise
2700 2695 if not exit_ignore:
2701 2696 self.showtraceback(exception_only=True)
2702 2697 except:
2703 2698 if raise_exceptions:
2704 2699 raise
2705 2700 # tb offset is 2 because we wrap execfile
2706 2701 self.showtraceback(tb_offset=2)
2707 2702
2708 2703 def safe_execfile_ipy(self, fname, shell_futures=False, raise_exceptions=False):
2709 2704 """Like safe_execfile, but for .ipy or .ipynb files with IPython syntax.
2710 2705
2711 2706 Parameters
2712 2707 ----------
2713 2708 fname : str
2714 2709 The name of the file to execute. The filename must have a
2715 2710 .ipy or .ipynb extension.
2716 2711 shell_futures : bool (False)
2717 2712 If True, the code will share future statements with the interactive
2718 2713 shell. It will both be affected by previous __future__ imports, and
2719 2714 any __future__ imports in the code will affect the shell. If False,
2720 2715 __future__ imports are not shared in either direction.
2721 2716 raise_exceptions : bool (False)
2722 2717 If True raise exceptions everywhere. Meant for testing.
2723 2718 """
2724 2719 fname = Path(fname).expanduser().resolve()
2725 2720
2726 2721 # Make sure we can open the file
2727 2722 try:
2728 2723 with fname.open("rb"):
2729 2724 pass
2730 2725 except:
2731 2726 warn('Could not open file <%s> for safe execution.' % fname)
2732 2727 return
2733 2728
2734 2729 # Find things also in current directory. This is needed to mimic the
2735 2730 # behavior of running a script from the system command line, where
2736 2731 # Python inserts the script's directory into sys.path
2737 2732 dname = str(fname.parent)
2738 2733
2739 2734 def get_cells():
2740 2735 """generator for sequence of code blocks to run"""
2741 2736 if fname.suffix == ".ipynb":
2742 2737 from nbformat import read
2743 2738 nb = read(fname, as_version=4)
2744 2739 if not nb.cells:
2745 2740 return
2746 2741 for cell in nb.cells:
2747 2742 if cell.cell_type == 'code':
2748 2743 yield cell.source
2749 2744 else:
2750 2745 yield fname.read_text(encoding="utf-8")
2751 2746
2752 2747 with prepended_to_syspath(dname):
2753 2748 try:
2754 2749 for cell in get_cells():
2755 2750 result = self.run_cell(cell, silent=True, shell_futures=shell_futures)
2756 2751 if raise_exceptions:
2757 2752 result.raise_error()
2758 2753 elif not result.success:
2759 2754 break
2760 2755 except:
2761 2756 if raise_exceptions:
2762 2757 raise
2763 2758 self.showtraceback()
2764 2759 warn('Unknown failure executing file: <%s>' % fname)
2765 2760
2766 2761 def safe_run_module(self, mod_name, where):
2767 2762 """A safe version of runpy.run_module().
2768 2763
2769 2764 This version will never throw an exception, but instead print
2770 2765 helpful error messages to the screen.
2771 2766
2772 2767 `SystemExit` exceptions with status code 0 or None are ignored.
2773 2768
2774 2769 Parameters
2775 2770 ----------
2776 2771 mod_name : string
2777 2772 The name of the module to be executed.
2778 2773 where : dict
2779 2774 The globals namespace.
2780 2775 """
2781 2776 try:
2782 2777 try:
2783 2778 where.update(
2784 2779 runpy.run_module(str(mod_name), run_name="__main__",
2785 2780 alter_sys=True)
2786 2781 )
2787 2782 except SystemExit as status:
2788 2783 if status.code:
2789 2784 raise
2790 2785 except:
2791 2786 self.showtraceback()
2792 2787 warn('Unknown failure executing module: <%s>' % mod_name)
2793 2788
2794 2789 def run_cell(self, raw_cell, store_history=False, silent=False, shell_futures=True):
2795 2790 """Run a complete IPython cell.
2796 2791
2797 2792 Parameters
2798 2793 ----------
2799 2794 raw_cell : str
2800 2795 The code (including IPython code such as %magic functions) to run.
2801 2796 store_history : bool
2802 2797 If True, the raw and translated cell will be stored in IPython's
2803 2798 history. For user code calling back into IPython's machinery, this
2804 2799 should be set to False.
2805 2800 silent : bool
2806 2801 If True, avoid side-effects, such as implicit displayhooks and
2807 2802 and logging. silent=True forces store_history=False.
2808 2803 shell_futures : bool
2809 2804 If True, the code will share future statements with the interactive
2810 2805 shell. It will both be affected by previous __future__ imports, and
2811 2806 any __future__ imports in the code will affect the shell. If False,
2812 2807 __future__ imports are not shared in either direction.
2813 2808
2814 2809 Returns
2815 2810 -------
2816 2811 result : :class:`ExecutionResult`
2817 2812 """
2818 2813 result = None
2819 2814 try:
2820 2815 result = self._run_cell(
2821 2816 raw_cell, store_history, silent, shell_futures)
2822 2817 finally:
2823 2818 self.events.trigger('post_execute')
2824 2819 if not silent:
2825 2820 self.events.trigger('post_run_cell', result)
2826 2821 return result
2827 2822
2828 2823 def _run_cell(self, raw_cell:str, store_history:bool, silent:bool, shell_futures:bool) -> ExecutionResult:
2829 2824 """Internal method to run a complete IPython cell."""
2830 2825
2831 2826 # we need to avoid calling self.transform_cell multiple time on the same thing
2832 2827 # so we need to store some results:
2833 2828 preprocessing_exc_tuple = None
2834 2829 try:
2835 2830 transformed_cell = self.transform_cell(raw_cell)
2836 2831 except Exception:
2837 2832 transformed_cell = raw_cell
2838 2833 preprocessing_exc_tuple = sys.exc_info()
2839 2834
2840 2835 assert transformed_cell is not None
2841 2836 coro = self.run_cell_async(
2842 2837 raw_cell,
2843 2838 store_history=store_history,
2844 2839 silent=silent,
2845 2840 shell_futures=shell_futures,
2846 2841 transformed_cell=transformed_cell,
2847 2842 preprocessing_exc_tuple=preprocessing_exc_tuple,
2848 2843 )
2849 2844
2850 2845 # run_cell_async is async, but may not actually need an eventloop.
2851 2846 # when this is the case, we want to run it using the pseudo_sync_runner
2852 2847 # so that code can invoke eventloops (for example via the %run , and
2853 2848 # `%paste` magic.
2854 2849 if self.trio_runner:
2855 2850 runner = self.trio_runner
2856 2851 elif self.should_run_async(
2857 2852 raw_cell,
2858 2853 transformed_cell=transformed_cell,
2859 2854 preprocessing_exc_tuple=preprocessing_exc_tuple,
2860 2855 ):
2861 2856 runner = self.loop_runner
2862 2857 else:
2863 2858 runner = _pseudo_sync_runner
2864 2859
2865 2860 try:
2866 2861 return runner(coro)
2867 2862 except BaseException as e:
2868 2863 info = ExecutionInfo(raw_cell, store_history, silent, shell_futures)
2869 2864 result = ExecutionResult(info)
2870 2865 result.error_in_exec = e
2871 2866 self.showtraceback(running_compiled_code=True)
2872 2867 return result
2873 2868
2874 2869 def should_run_async(
2875 2870 self, raw_cell: str, *, transformed_cell=None, preprocessing_exc_tuple=None
2876 2871 ) -> bool:
2877 2872 """Return whether a cell should be run asynchronously via a coroutine runner
2878 2873
2879 2874 Parameters
2880 2875 ----------
2881 2876 raw_cell : str
2882 2877 The code to be executed
2883 2878
2884 2879 Returns
2885 2880 -------
2886 2881 result: bool
2887 2882 Whether the code needs to be run with a coroutine runner or not
2888 2883 .. versionadded:: 7.0
2889 2884 """
2890 2885 if not self.autoawait:
2891 2886 return False
2892 2887 if preprocessing_exc_tuple is not None:
2893 2888 return False
2894 2889 assert preprocessing_exc_tuple is None
2895 2890 if transformed_cell is None:
2896 2891 warnings.warn(
2897 2892 "`should_run_async` will not call `transform_cell`"
2898 2893 " automatically in the future. Please pass the result to"
2899 2894 " `transformed_cell` argument and any exception that happen"
2900 2895 " during the"
2901 2896 "transform in `preprocessing_exc_tuple` in"
2902 2897 " IPython 7.17 and above.",
2903 2898 DeprecationWarning,
2904 2899 stacklevel=2,
2905 2900 )
2906 2901 try:
2907 2902 cell = self.transform_cell(raw_cell)
2908 2903 except Exception:
2909 2904 # any exception during transform will be raised
2910 2905 # prior to execution
2911 2906 return False
2912 2907 else:
2913 2908 cell = transformed_cell
2914 2909 return _should_be_async(cell)
2915 2910
2916 2911 async def run_cell_async(
2917 2912 self,
2918 2913 raw_cell: str,
2919 2914 store_history=False,
2920 2915 silent=False,
2921 2916 shell_futures=True,
2922 2917 *,
2923 2918 transformed_cell: Optional[str] = None,
2924 2919 preprocessing_exc_tuple: Optional[Any] = None
2925 2920 ) -> ExecutionResult:
2926 2921 """Run a complete IPython cell asynchronously.
2927 2922
2928 2923 Parameters
2929 2924 ----------
2930 2925 raw_cell : str
2931 2926 The code (including IPython code such as %magic functions) to run.
2932 2927 store_history : bool
2933 2928 If True, the raw and translated cell will be stored in IPython's
2934 2929 history. For user code calling back into IPython's machinery, this
2935 2930 should be set to False.
2936 2931 silent : bool
2937 2932 If True, avoid side-effects, such as implicit displayhooks and
2938 2933 and logging. silent=True forces store_history=False.
2939 2934 shell_futures : bool
2940 2935 If True, the code will share future statements with the interactive
2941 2936 shell. It will both be affected by previous __future__ imports, and
2942 2937 any __future__ imports in the code will affect the shell. If False,
2943 2938 __future__ imports are not shared in either direction.
2944 2939 transformed_cell: str
2945 2940 cell that was passed through transformers
2946 2941 preprocessing_exc_tuple:
2947 2942 trace if the transformation failed.
2948 2943
2949 2944 Returns
2950 2945 -------
2951 2946 result : :class:`ExecutionResult`
2952 2947
2953 2948 .. versionadded:: 7.0
2954 2949 """
2955 2950 info = ExecutionInfo(
2956 2951 raw_cell, store_history, silent, shell_futures)
2957 2952 result = ExecutionResult(info)
2958 2953
2959 2954 if (not raw_cell) or raw_cell.isspace():
2960 2955 self.last_execution_succeeded = True
2961 2956 self.last_execution_result = result
2962 2957 return result
2963 2958
2964 2959 if silent:
2965 2960 store_history = False
2966 2961
2967 2962 if store_history:
2968 2963 result.execution_count = self.execution_count
2969 2964
2970 2965 def error_before_exec(value):
2971 2966 if store_history:
2972 2967 self.execution_count += 1
2973 2968 result.error_before_exec = value
2974 2969 self.last_execution_succeeded = False
2975 2970 self.last_execution_result = result
2976 2971 return result
2977 2972
2978 2973 self.events.trigger('pre_execute')
2979 2974 if not silent:
2980 2975 self.events.trigger('pre_run_cell', info)
2981 2976
2982 2977 if transformed_cell is None:
2983 2978 warnings.warn(
2984 2979 "`run_cell_async` will not call `transform_cell`"
2985 2980 " automatically in the future. Please pass the result to"
2986 2981 " `transformed_cell` argument and any exception that happen"
2987 2982 " during the"
2988 2983 "transform in `preprocessing_exc_tuple` in"
2989 2984 " IPython 7.17 and above.",
2990 2985 DeprecationWarning,
2991 2986 stacklevel=2,
2992 2987 )
2993 2988 # If any of our input transformation (input_transformer_manager or
2994 2989 # prefilter_manager) raises an exception, we store it in this variable
2995 2990 # so that we can display the error after logging the input and storing
2996 2991 # it in the history.
2997 2992 try:
2998 2993 cell = self.transform_cell(raw_cell)
2999 2994 except Exception:
3000 2995 preprocessing_exc_tuple = sys.exc_info()
3001 2996 cell = raw_cell # cell has to exist so it can be stored/logged
3002 2997 else:
3003 2998 preprocessing_exc_tuple = None
3004 2999 else:
3005 3000 if preprocessing_exc_tuple is None:
3006 3001 cell = transformed_cell
3007 3002 else:
3008 3003 cell = raw_cell
3009 3004
3010 3005 # Store raw and processed history
3011 3006 if store_history:
3012 3007 self.history_manager.store_inputs(self.execution_count,
3013 3008 cell, raw_cell)
3014 3009 if not silent:
3015 3010 self.logger.log(cell, raw_cell)
3016 3011
3017 3012 # Display the exception if input processing failed.
3018 3013 if preprocessing_exc_tuple is not None:
3019 3014 self.showtraceback(preprocessing_exc_tuple)
3020 3015 if store_history:
3021 3016 self.execution_count += 1
3022 3017 return error_before_exec(preprocessing_exc_tuple[1])
3023 3018
3024 3019 # Our own compiler remembers the __future__ environment. If we want to
3025 3020 # run code with a separate __future__ environment, use the default
3026 3021 # compiler
3027 3022 compiler = self.compile if shell_futures else self.compiler_class()
3028 3023
3029 3024 _run_async = False
3030 3025
3031 3026 with self.builtin_trap:
3032 3027 cell_name = compiler.cache(cell, self.execution_count, raw_code=raw_cell)
3033 3028
3034 3029 with self.display_trap:
3035 3030 # Compile to bytecode
3036 3031 try:
3037 3032 code_ast = compiler.ast_parse(cell, filename=cell_name)
3038 3033 except self.custom_exceptions as e:
3039 3034 etype, value, tb = sys.exc_info()
3040 3035 self.CustomTB(etype, value, tb)
3041 3036 return error_before_exec(e)
3042 3037 except IndentationError as e:
3043 3038 self.showindentationerror()
3044 3039 return error_before_exec(e)
3045 3040 except (OverflowError, SyntaxError, ValueError, TypeError,
3046 3041 MemoryError) as e:
3047 3042 self.showsyntaxerror()
3048 3043 return error_before_exec(e)
3049 3044
3050 3045 # Apply AST transformations
3051 3046 try:
3052 3047 code_ast = self.transform_ast(code_ast)
3053 3048 except InputRejected as e:
3054 3049 self.showtraceback()
3055 3050 return error_before_exec(e)
3056 3051
3057 3052 # Give the displayhook a reference to our ExecutionResult so it
3058 3053 # can fill in the output value.
3059 3054 self.displayhook.exec_result = result
3060 3055
3061 3056 # Execute the user code
3062 3057 interactivity = "none" if silent else self.ast_node_interactivity
3063 3058
3064 3059 has_raised = await self.run_ast_nodes(code_ast.body, cell_name,
3065 3060 interactivity=interactivity, compiler=compiler, result=result)
3066 3061
3067 3062 self.last_execution_succeeded = not has_raised
3068 3063 self.last_execution_result = result
3069 3064
3070 3065 # Reset this so later displayed values do not modify the
3071 3066 # ExecutionResult
3072 3067 self.displayhook.exec_result = None
3073 3068
3074 3069 if store_history:
3075 3070 # Write output to the database. Does nothing unless
3076 3071 # history output logging is enabled.
3077 3072 self.history_manager.store_output(self.execution_count)
3078 3073 # Each cell is a *single* input, regardless of how many lines it has
3079 3074 self.execution_count += 1
3080 3075
3081 3076 return result
3082 3077
3083 3078 def transform_cell(self, raw_cell):
3084 3079 """Transform an input cell before parsing it.
3085 3080
3086 3081 Static transformations, implemented in IPython.core.inputtransformer2,
3087 3082 deal with things like ``%magic`` and ``!system`` commands.
3088 3083 These run on all input.
3089 3084 Dynamic transformations, for things like unescaped magics and the exit
3090 3085 autocall, depend on the state of the interpreter.
3091 3086 These only apply to single line inputs.
3092 3087
3093 3088 These string-based transformations are followed by AST transformations;
3094 3089 see :meth:`transform_ast`.
3095 3090 """
3096 3091 # Static input transformations
3097 3092 cell = self.input_transformer_manager.transform_cell(raw_cell)
3098 3093
3099 3094 if len(cell.splitlines()) == 1:
3100 3095 # Dynamic transformations - only applied for single line commands
3101 3096 with self.builtin_trap:
3102 3097 # use prefilter_lines to handle trailing newlines
3103 3098 # restore trailing newline for ast.parse
3104 3099 cell = self.prefilter_manager.prefilter_lines(cell) + '\n'
3105 3100
3106 3101 lines = cell.splitlines(keepends=True)
3107 3102 for transform in self.input_transformers_post:
3108 3103 lines = transform(lines)
3109 3104 cell = ''.join(lines)
3110 3105
3111 3106 return cell
3112 3107
3113 3108 def transform_ast(self, node):
3114 3109 """Apply the AST transformations from self.ast_transformers
3115 3110
3116 3111 Parameters
3117 3112 ----------
3118 3113 node : ast.Node
3119 3114 The root node to be transformed. Typically called with the ast.Module
3120 3115 produced by parsing user input.
3121 3116
3122 3117 Returns
3123 3118 -------
3124 3119 An ast.Node corresponding to the node it was called with. Note that it
3125 3120 may also modify the passed object, so don't rely on references to the
3126 3121 original AST.
3127 3122 """
3128 3123 for transformer in self.ast_transformers:
3129 3124 try:
3130 3125 node = transformer.visit(node)
3131 3126 except InputRejected:
3132 3127 # User-supplied AST transformers can reject an input by raising
3133 3128 # an InputRejected. Short-circuit in this case so that we
3134 3129 # don't unregister the transform.
3135 3130 raise
3136 3131 except Exception:
3137 3132 warn("AST transformer %r threw an error. It will be unregistered." % transformer)
3138 3133 self.ast_transformers.remove(transformer)
3139 3134
3140 3135 if self.ast_transformers:
3141 3136 ast.fix_missing_locations(node)
3142 3137 return node
3143 3138
3144 3139 async def run_ast_nodes(
3145 3140 self,
3146 3141 nodelist: ListType[stmt],
3147 3142 cell_name: str,
3148 3143 interactivity="last_expr",
3149 3144 compiler=compile,
3150 3145 result=None,
3151 3146 ):
3152 3147 """Run a sequence of AST nodes. The execution mode depends on the
3153 3148 interactivity parameter.
3154 3149
3155 3150 Parameters
3156 3151 ----------
3157 3152 nodelist : list
3158 3153 A sequence of AST nodes to run.
3159 3154 cell_name : str
3160 3155 Will be passed to the compiler as the filename of the cell. Typically
3161 3156 the value returned by ip.compile.cache(cell).
3162 3157 interactivity : str
3163 3158 'all', 'last', 'last_expr' , 'last_expr_or_assign' or 'none',
3164 3159 specifying which nodes should be run interactively (displaying output
3165 3160 from expressions). 'last_expr' will run the last node interactively
3166 3161 only if it is an expression (i.e. expressions in loops or other blocks
3167 3162 are not displayed) 'last_expr_or_assign' will run the last expression
3168 3163 or the last assignment. Other values for this parameter will raise a
3169 3164 ValueError.
3170 3165
3171 3166 compiler : callable
3172 3167 A function with the same interface as the built-in compile(), to turn
3173 3168 the AST nodes into code objects. Default is the built-in compile().
3174 3169 result : ExecutionResult, optional
3175 3170 An object to store exceptions that occur during execution.
3176 3171
3177 3172 Returns
3178 3173 -------
3179 3174 True if an exception occurred while running code, False if it finished
3180 3175 running.
3181 3176 """
3182 3177 if not nodelist:
3183 3178 return
3184 3179
3185 3180
3186 3181 if interactivity == 'last_expr_or_assign':
3187 3182 if isinstance(nodelist[-1], _assign_nodes):
3188 3183 asg = nodelist[-1]
3189 3184 if isinstance(asg, ast.Assign) and len(asg.targets) == 1:
3190 3185 target = asg.targets[0]
3191 3186 elif isinstance(asg, _single_targets_nodes):
3192 3187 target = asg.target
3193 3188 else:
3194 3189 target = None
3195 3190 if isinstance(target, ast.Name):
3196 3191 nnode = ast.Expr(ast.Name(target.id, ast.Load()))
3197 3192 ast.fix_missing_locations(nnode)
3198 3193 nodelist.append(nnode)
3199 3194 interactivity = 'last_expr'
3200 3195
3201 3196 _async = False
3202 3197 if interactivity == 'last_expr':
3203 3198 if isinstance(nodelist[-1], ast.Expr):
3204 3199 interactivity = "last"
3205 3200 else:
3206 3201 interactivity = "none"
3207 3202
3208 3203 if interactivity == 'none':
3209 3204 to_run_exec, to_run_interactive = nodelist, []
3210 3205 elif interactivity == 'last':
3211 3206 to_run_exec, to_run_interactive = nodelist[:-1], nodelist[-1:]
3212 3207 elif interactivity == 'all':
3213 3208 to_run_exec, to_run_interactive = [], nodelist
3214 3209 else:
3215 3210 raise ValueError("Interactivity was %r" % interactivity)
3216 3211
3217 3212 try:
3218 3213
3219 3214 def compare(code):
3220 3215 is_async = inspect.CO_COROUTINE & code.co_flags == inspect.CO_COROUTINE
3221 3216 return is_async
3222 3217
3223 3218 # refactor that to just change the mod constructor.
3224 3219 to_run = []
3225 3220 for node in to_run_exec:
3226 3221 to_run.append((node, "exec"))
3227 3222
3228 3223 for node in to_run_interactive:
3229 3224 to_run.append((node, "single"))
3230 3225
3231 3226 for node, mode in to_run:
3232 3227 if mode == "exec":
3233 3228 mod = Module([node], [])
3234 3229 elif mode == "single":
3235 3230 mod = ast.Interactive([node])
3236 3231 with compiler.extra_flags(
3237 3232 getattr(ast, "PyCF_ALLOW_TOP_LEVEL_AWAIT", 0x0)
3238 3233 if self.autoawait
3239 3234 else 0x0
3240 3235 ):
3241 3236 code = compiler(mod, cell_name, mode)
3242 3237 asy = compare(code)
3243 3238 if await self.run_code(code, result, async_=asy):
3244 3239 return True
3245 3240
3246 3241 # Flush softspace
3247 3242 if softspace(sys.stdout, 0):
3248 3243 print()
3249 3244
3250 3245 except:
3251 3246 # It's possible to have exceptions raised here, typically by
3252 3247 # compilation of odd code (such as a naked 'return' outside a
3253 3248 # function) that did parse but isn't valid. Typically the exception
3254 3249 # is a SyntaxError, but it's safest just to catch anything and show
3255 3250 # the user a traceback.
3256 3251
3257 3252 # We do only one try/except outside the loop to minimize the impact
3258 3253 # on runtime, and also because if any node in the node list is
3259 3254 # broken, we should stop execution completely.
3260 3255 if result:
3261 3256 result.error_before_exec = sys.exc_info()[1]
3262 3257 self.showtraceback()
3263 3258 return True
3264 3259
3265 3260 return False
3266 3261
3267 3262 async def run_code(self, code_obj, result=None, *, async_=False):
3268 3263 """Execute a code object.
3269 3264
3270 3265 When an exception occurs, self.showtraceback() is called to display a
3271 3266 traceback.
3272 3267
3273 3268 Parameters
3274 3269 ----------
3275 3270 code_obj : code object
3276 3271 A compiled code object, to be executed
3277 3272 result : ExecutionResult, optional
3278 3273 An object to store exceptions that occur during execution.
3279 3274 async_ : Bool (Experimental)
3280 3275 Attempt to run top-level asynchronous code in a default loop.
3281 3276
3282 3277 Returns
3283 3278 -------
3284 3279 False : successful execution.
3285 3280 True : an error occurred.
3286 3281 """
3287 3282 # special value to say that anything above is IPython and should be
3288 3283 # hidden.
3289 3284 __tracebackhide__ = "__ipython_bottom__"
3290 3285 # Set our own excepthook in case the user code tries to call it
3291 3286 # directly, so that the IPython crash handler doesn't get triggered
3292 3287 old_excepthook, sys.excepthook = sys.excepthook, self.excepthook
3293 3288
3294 3289 # we save the original sys.excepthook in the instance, in case config
3295 3290 # code (such as magics) needs access to it.
3296 3291 self.sys_excepthook = old_excepthook
3297 3292 outflag = True # happens in more places, so it's easier as default
3298 3293 try:
3299 3294 try:
3300 3295 if async_:
3301 3296 await eval(code_obj, self.user_global_ns, self.user_ns)
3302 3297 else:
3303 3298 exec(code_obj, self.user_global_ns, self.user_ns)
3304 3299 finally:
3305 3300 # Reset our crash handler in place
3306 3301 sys.excepthook = old_excepthook
3307 3302 except SystemExit as e:
3308 3303 if result is not None:
3309 3304 result.error_in_exec = e
3310 3305 self.showtraceback(exception_only=True)
3311 3306 warn("To exit: use 'exit', 'quit', or Ctrl-D.", stacklevel=1)
3312 3307 except self.custom_exceptions:
3313 3308 etype, value, tb = sys.exc_info()
3314 3309 if result is not None:
3315 3310 result.error_in_exec = value
3316 3311 self.CustomTB(etype, value, tb)
3317 3312 except:
3318 3313 if result is not None:
3319 3314 result.error_in_exec = sys.exc_info()[1]
3320 3315 self.showtraceback(running_compiled_code=True)
3321 3316 else:
3322 3317 outflag = False
3323 3318 return outflag
3324 3319
3325 3320 # For backwards compatibility
3326 3321 runcode = run_code
3327 3322
3328 3323 def check_complete(self, code: str) -> Tuple[str, str]:
3329 3324 """Return whether a block of code is ready to execute, or should be continued
3330 3325
3331 3326 Parameters
3332 3327 ----------
3333 3328 code : string
3334 3329 Python input code, which can be multiline.
3335 3330
3336 3331 Returns
3337 3332 -------
3338 3333 status : str
3339 3334 One of 'complete', 'incomplete', or 'invalid' if source is not a
3340 3335 prefix of valid code.
3341 3336 indent : str
3342 3337 When status is 'incomplete', this is some whitespace to insert on
3343 3338 the next line of the prompt.
3344 3339 """
3345 3340 status, nspaces = self.input_transformer_manager.check_complete(code)
3346 3341 return status, ' ' * (nspaces or 0)
3347 3342
3348 3343 #-------------------------------------------------------------------------
3349 3344 # Things related to GUI support and pylab
3350 3345 #-------------------------------------------------------------------------
3351 3346
3352 3347 active_eventloop = None
3353 3348
3354 3349 def enable_gui(self, gui=None):
3355 3350 raise NotImplementedError('Implement enable_gui in a subclass')
3356 3351
3357 3352 def enable_matplotlib(self, gui=None):
3358 3353 """Enable interactive matplotlib and inline figure support.
3359 3354
3360 3355 This takes the following steps:
3361 3356
3362 3357 1. select the appropriate eventloop and matplotlib backend
3363 3358 2. set up matplotlib for interactive use with that backend
3364 3359 3. configure formatters for inline figure display
3365 3360 4. enable the selected gui eventloop
3366 3361
3367 3362 Parameters
3368 3363 ----------
3369 3364 gui : optional, string
3370 3365 If given, dictates the choice of matplotlib GUI backend to use
3371 3366 (should be one of IPython's supported backends, 'qt', 'osx', 'tk',
3372 3367 'gtk', 'wx' or 'inline'), otherwise we use the default chosen by
3373 3368 matplotlib (as dictated by the matplotlib build-time options plus the
3374 3369 user's matplotlibrc configuration file). Note that not all backends
3375 3370 make sense in all contexts, for example a terminal ipython can't
3376 3371 display figures inline.
3377 3372 """
3378 3373 from IPython.core import pylabtools as pt
3379 3374 from matplotlib_inline.backend_inline import configure_inline_support
3380 3375 gui, backend = pt.find_gui_and_backend(gui, self.pylab_gui_select)
3381 3376
3382 3377 if gui != 'inline':
3383 3378 # If we have our first gui selection, store it
3384 3379 if self.pylab_gui_select is None:
3385 3380 self.pylab_gui_select = gui
3386 3381 # Otherwise if they are different
3387 3382 elif gui != self.pylab_gui_select:
3388 3383 print('Warning: Cannot change to a different GUI toolkit: %s.'
3389 3384 ' Using %s instead.' % (gui, self.pylab_gui_select))
3390 3385 gui, backend = pt.find_gui_and_backend(self.pylab_gui_select)
3391 3386
3392 3387 pt.activate_matplotlib(backend)
3393 3388 configure_inline_support(self, backend)
3394 3389
3395 3390 # Now we must activate the gui pylab wants to use, and fix %run to take
3396 3391 # plot updates into account
3397 3392 self.enable_gui(gui)
3398 3393 self.magics_manager.registry['ExecutionMagics'].default_runner = \
3399 3394 pt.mpl_runner(self.safe_execfile)
3400 3395
3401 3396 return gui, backend
3402 3397
3403 3398 def enable_pylab(self, gui=None, import_all=True, welcome_message=False):
3404 3399 """Activate pylab support at runtime.
3405 3400
3406 3401 This turns on support for matplotlib, preloads into the interactive
3407 3402 namespace all of numpy and pylab, and configures IPython to correctly
3408 3403 interact with the GUI event loop. The GUI backend to be used can be
3409 3404 optionally selected with the optional ``gui`` argument.
3410 3405
3411 3406 This method only adds preloading the namespace to InteractiveShell.enable_matplotlib.
3412 3407
3413 3408 Parameters
3414 3409 ----------
3415 3410 gui : optional, string
3416 3411 If given, dictates the choice of matplotlib GUI backend to use
3417 3412 (should be one of IPython's supported backends, 'qt', 'osx', 'tk',
3418 3413 'gtk', 'wx' or 'inline'), otherwise we use the default chosen by
3419 3414 matplotlib (as dictated by the matplotlib build-time options plus the
3420 3415 user's matplotlibrc configuration file). Note that not all backends
3421 3416 make sense in all contexts, for example a terminal ipython can't
3422 3417 display figures inline.
3423 3418 import_all : optional, bool, default: True
3424 3419 Whether to do `from numpy import *` and `from pylab import *`
3425 3420 in addition to module imports.
3426 3421 welcome_message : deprecated
3427 3422 This argument is ignored, no welcome message will be displayed.
3428 3423 """
3429 3424 from IPython.core.pylabtools import import_pylab
3430 3425
3431 3426 gui, backend = self.enable_matplotlib(gui)
3432 3427
3433 3428 # We want to prevent the loading of pylab to pollute the user's
3434 3429 # namespace as shown by the %who* magics, so we execute the activation
3435 3430 # code in an empty namespace, and we update *both* user_ns and
3436 3431 # user_ns_hidden with this information.
3437 3432 ns = {}
3438 3433 import_pylab(ns, import_all)
3439 3434 # warn about clobbered names
3440 3435 ignored = {"__builtins__"}
3441 3436 both = set(ns).intersection(self.user_ns).difference(ignored)
3442 3437 clobbered = [ name for name in both if self.user_ns[name] is not ns[name] ]
3443 3438 self.user_ns.update(ns)
3444 3439 self.user_ns_hidden.update(ns)
3445 3440 return gui, backend, clobbered
3446 3441
3447 3442 #-------------------------------------------------------------------------
3448 3443 # Utilities
3449 3444 #-------------------------------------------------------------------------
3450 3445
3451 3446 def var_expand(self, cmd, depth=0, formatter=DollarFormatter()):
3452 3447 """Expand python variables in a string.
3453 3448
3454 3449 The depth argument indicates how many frames above the caller should
3455 3450 be walked to look for the local namespace where to expand variables.
3456 3451
3457 3452 The global namespace for expansion is always the user's interactive
3458 3453 namespace.
3459 3454 """
3460 3455 ns = self.user_ns.copy()
3461 3456 try:
3462 3457 frame = sys._getframe(depth+1)
3463 3458 except ValueError:
3464 3459 # This is thrown if there aren't that many frames on the stack,
3465 3460 # e.g. if a script called run_line_magic() directly.
3466 3461 pass
3467 3462 else:
3468 3463 ns.update(frame.f_locals)
3469 3464
3470 3465 try:
3471 3466 # We have to use .vformat() here, because 'self' is a valid and common
3472 3467 # name, and expanding **ns for .format() would make it collide with
3473 3468 # the 'self' argument of the method.
3474 3469 cmd = formatter.vformat(cmd, args=[], kwargs=ns)
3475 3470 except Exception:
3476 3471 # if formatter couldn't format, just let it go untransformed
3477 3472 pass
3478 3473 return cmd
3479 3474
3480 3475 def mktempfile(self, data=None, prefix='ipython_edit_'):
3481 3476 """Make a new tempfile and return its filename.
3482 3477
3483 3478 This makes a call to tempfile.mkstemp (created in a tempfile.mkdtemp),
3484 3479 but it registers the created filename internally so ipython cleans it up
3485 3480 at exit time.
3486 3481
3487 3482 Optional inputs:
3488 3483
3489 3484 - data(None): if data is given, it gets written out to the temp file
3490 3485 immediately, and the file is closed again."""
3491 3486
3492 3487 dir_path = Path(tempfile.mkdtemp(prefix=prefix))
3493 3488 self.tempdirs.append(dir_path)
3494 3489
3495 3490 handle, filename = tempfile.mkstemp(".py", prefix, dir=str(dir_path))
3496 3491 os.close(handle) # On Windows, there can only be one open handle on a file
3497 3492
3498 3493 file_path = Path(filename)
3499 3494 self.tempfiles.append(file_path)
3500 3495
3501 3496 if data:
3502 3497 file_path.write_text(data, encoding="utf-8")
3503 3498 return filename
3504 3499
3505 3500 def ask_yes_no(self, prompt, default=None, interrupt=None):
3506 3501 if self.quiet:
3507 3502 return True
3508 3503 return ask_yes_no(prompt,default,interrupt)
3509 3504
3510 3505 def show_usage(self):
3511 3506 """Show a usage message"""
3512 3507 page.page(IPython.core.usage.interactive_usage)
3513 3508
3514 3509 def extract_input_lines(self, range_str, raw=False):
3515 3510 """Return as a string a set of input history slices.
3516 3511
3517 3512 Parameters
3518 3513 ----------
3519 3514 range_str : str
3520 3515 The set of slices is given as a string, like "~5/6-~4/2 4:8 9",
3521 3516 since this function is for use by magic functions which get their
3522 3517 arguments as strings. The number before the / is the session
3523 3518 number: ~n goes n back from the current session.
3524 3519
3525 3520 If empty string is given, returns history of current session
3526 3521 without the last input.
3527 3522
3528 3523 raw : bool, optional
3529 3524 By default, the processed input is used. If this is true, the raw
3530 3525 input history is used instead.
3531 3526
3532 3527 Notes
3533 3528 -----
3534 3529 Slices can be described with two notations:
3535 3530
3536 3531 * ``N:M`` -> standard python form, means including items N...(M-1).
3537 3532 * ``N-M`` -> include items N..M (closed endpoint).
3538 3533 """
3539 3534 lines = self.history_manager.get_range_by_str(range_str, raw=raw)
3540 3535 text = "\n".join(x for _, _, x in lines)
3541 3536
3542 3537 # Skip the last line, as it's probably the magic that called this
3543 3538 if not range_str:
3544 3539 if "\n" not in text:
3545 3540 text = ""
3546 3541 else:
3547 3542 text = text[: text.rfind("\n")]
3548 3543
3549 3544 return text
3550 3545
3551 3546 def find_user_code(self, target, raw=True, py_only=False, skip_encoding_cookie=True, search_ns=False):
3552 3547 """Get a code string from history, file, url, or a string or macro.
3553 3548
3554 3549 This is mainly used by magic functions.
3555 3550
3556 3551 Parameters
3557 3552 ----------
3558 3553 target : str
3559 3554 A string specifying code to retrieve. This will be tried respectively
3560 3555 as: ranges of input history (see %history for syntax), url,
3561 3556 corresponding .py file, filename, or an expression evaluating to a
3562 3557 string or Macro in the user namespace.
3563 3558
3564 3559 If empty string is given, returns complete history of current
3565 3560 session, without the last line.
3566 3561
3567 3562 raw : bool
3568 3563 If true (default), retrieve raw history. Has no effect on the other
3569 3564 retrieval mechanisms.
3570 3565
3571 3566 py_only : bool (default False)
3572 3567 Only try to fetch python code, do not try alternative methods to decode file
3573 3568 if unicode fails.
3574 3569
3575 3570 Returns
3576 3571 -------
3577 3572 A string of code.
3578 3573 ValueError is raised if nothing is found, and TypeError if it evaluates
3579 3574 to an object of another type. In each case, .args[0] is a printable
3580 3575 message.
3581 3576 """
3582 3577 code = self.extract_input_lines(target, raw=raw) # Grab history
3583 3578 if code:
3584 3579 return code
3585 3580 try:
3586 3581 if target.startswith(('http://', 'https://')):
3587 3582 return openpy.read_py_url(target, skip_encoding_cookie=skip_encoding_cookie)
3588 3583 except UnicodeDecodeError as e:
3589 3584 if not py_only :
3590 3585 # Deferred import
3591 3586 from urllib.request import urlopen
3592 3587 response = urlopen(target)
3593 3588 return response.read().decode('latin1')
3594 3589 raise ValueError(("'%s' seem to be unreadable.") % target) from e
3595 3590
3596 3591 potential_target = [target]
3597 3592 try :
3598 3593 potential_target.insert(0,get_py_filename(target))
3599 3594 except IOError:
3600 3595 pass
3601 3596
3602 3597 for tgt in potential_target :
3603 3598 if os.path.isfile(tgt): # Read file
3604 3599 try :
3605 3600 return openpy.read_py_file(tgt, skip_encoding_cookie=skip_encoding_cookie)
3606 3601 except UnicodeDecodeError as e:
3607 3602 if not py_only :
3608 3603 with io_open(tgt,'r', encoding='latin1') as f :
3609 3604 return f.read()
3610 3605 raise ValueError(("'%s' seem to be unreadable.") % target) from e
3611 3606 elif os.path.isdir(os.path.expanduser(tgt)):
3612 3607 raise ValueError("'%s' is a directory, not a regular file." % target)
3613 3608
3614 3609 if search_ns:
3615 3610 # Inspect namespace to load object source
3616 3611 object_info = self.object_inspect(target, detail_level=1)
3617 3612 if object_info['found'] and object_info['source']:
3618 3613 return object_info['source']
3619 3614
3620 3615 try: # User namespace
3621 3616 codeobj = eval(target, self.user_ns)
3622 3617 except Exception as e:
3623 3618 raise ValueError(("'%s' was not found in history, as a file, url, "
3624 3619 "nor in the user namespace.") % target) from e
3625 3620
3626 3621 if isinstance(codeobj, str):
3627 3622 return codeobj
3628 3623 elif isinstance(codeobj, Macro):
3629 3624 return codeobj.value
3630 3625
3631 3626 raise TypeError("%s is neither a string nor a macro." % target,
3632 3627 codeobj)
3633 3628
3634 3629 def _atexit_once(self):
3635 3630 """
3636 3631 At exist operation that need to be called at most once.
3637 3632 Second call to this function per instance will do nothing.
3638 3633 """
3639 3634
3640 3635 if not getattr(self, "_atexit_once_called", False):
3641 3636 self._atexit_once_called = True
3642 3637 # Clear all user namespaces to release all references cleanly.
3643 3638 self.reset(new_session=False)
3644 3639 # Close the history session (this stores the end time and line count)
3645 3640 # this must be *before* the tempfile cleanup, in case of temporary
3646 3641 # history db
3647 3642 self.history_manager.end_session()
3648 3643 self.history_manager = None
3649 3644
3650 3645 #-------------------------------------------------------------------------
3651 3646 # Things related to IPython exiting
3652 3647 #-------------------------------------------------------------------------
3653 3648 def atexit_operations(self):
3654 3649 """This will be executed at the time of exit.
3655 3650
3656 3651 Cleanup operations and saving of persistent data that is done
3657 3652 unconditionally by IPython should be performed here.
3658 3653
3659 3654 For things that may depend on startup flags or platform specifics (such
3660 3655 as having readline or not), register a separate atexit function in the
3661 3656 code that has the appropriate information, rather than trying to
3662 3657 clutter
3663 3658 """
3664 3659 self._atexit_once()
3665 3660
3666 3661 # Cleanup all tempfiles and folders left around
3667 3662 for tfile in self.tempfiles:
3668 3663 try:
3669 3664 tfile.unlink()
3670 3665 self.tempfiles.remove(tfile)
3671 3666 except FileNotFoundError:
3672 3667 pass
3673 3668 del self.tempfiles
3674 3669 for tdir in self.tempdirs:
3675 3670 try:
3676 3671 tdir.rmdir()
3677 3672 self.tempdirs.remove(tdir)
3678 3673 except FileNotFoundError:
3679 3674 pass
3680 3675 del self.tempdirs
3681 3676
3682 3677
3683 3678 def cleanup(self):
3684 3679 self.restore_sys_module_state()
3685 3680
3686 3681
3687 3682 # Overridden in terminal subclass to change prompts
3688 3683 def switch_doctest_mode(self, mode):
3689 3684 pass
3690 3685
3691 3686
3692 3687 class InteractiveShellABC(metaclass=abc.ABCMeta):
3693 3688 """An abstract base class for InteractiveShell."""
3694 3689
3695 3690 InteractiveShellABC.register(InteractiveShell)
@@ -1,1100 +1,1100 b''
1 1 # -*- coding: utf-8 -*-
2 2 """Tests for the key interactiveshell module.
3 3
4 4 Historically the main classes in interactiveshell have been under-tested. This
5 5 module should grow as many single-method tests as possible to trap many of the
6 6 recurring bugs we seem to encounter with high-level interaction.
7 7 """
8 8
9 9 # Copyright (c) IPython Development Team.
10 10 # Distributed under the terms of the Modified BSD License.
11 11
12 12 import asyncio
13 13 import ast
14 14 import os
15 15 import signal
16 16 import shutil
17 17 import sys
18 18 import tempfile
19 19 import unittest
20 20 from unittest import mock
21 21
22 22 from os.path import join
23 23
24 24 from IPython.core.error import InputRejected
25 25 from IPython.core.inputtransformer import InputTransformer
26 26 from IPython.core import interactiveshell
27 27 from IPython.testing.decorators import (
28 28 skipif, skip_win32, onlyif_unicode_paths, onlyif_cmds_exist,
29 29 )
30 30 from IPython.testing import tools as tt
31 31 from IPython.utils.process import find_cmd
32 32
33 33 #-----------------------------------------------------------------------------
34 34 # Globals
35 35 #-----------------------------------------------------------------------------
36 36 # This is used by every single test, no point repeating it ad nauseam
37 37
38 38 #-----------------------------------------------------------------------------
39 39 # Tests
40 40 #-----------------------------------------------------------------------------
41 41
42 42 class DerivedInterrupt(KeyboardInterrupt):
43 43 pass
44 44
45 45 class InteractiveShellTestCase(unittest.TestCase):
46 46 def test_naked_string_cells(self):
47 47 """Test that cells with only naked strings are fully executed"""
48 48 # First, single-line inputs
49 49 ip.run_cell('"a"\n')
50 50 self.assertEqual(ip.user_ns['_'], 'a')
51 51 # And also multi-line cells
52 52 ip.run_cell('"""a\nb"""\n')
53 53 self.assertEqual(ip.user_ns['_'], 'a\nb')
54 54
55 55 def test_run_empty_cell(self):
56 56 """Just make sure we don't get a horrible error with a blank
57 57 cell of input. Yes, I did overlook that."""
58 58 old_xc = ip.execution_count
59 59 res = ip.run_cell('')
60 60 self.assertEqual(ip.execution_count, old_xc)
61 61 self.assertEqual(res.execution_count, None)
62 62
63 63 def test_run_cell_multiline(self):
64 64 """Multi-block, multi-line cells must execute correctly.
65 65 """
66 66 src = '\n'.join(["x=1",
67 67 "y=2",
68 68 "if 1:",
69 69 " x += 1",
70 70 " y += 1",])
71 71 res = ip.run_cell(src)
72 72 self.assertEqual(ip.user_ns['x'], 2)
73 73 self.assertEqual(ip.user_ns['y'], 3)
74 74 self.assertEqual(res.success, True)
75 75 self.assertEqual(res.result, None)
76 76
77 77 def test_multiline_string_cells(self):
78 78 "Code sprinkled with multiline strings should execute (GH-306)"
79 79 ip.run_cell('tmp=0')
80 80 self.assertEqual(ip.user_ns['tmp'], 0)
81 81 res = ip.run_cell('tmp=1;"""a\nb"""\n')
82 82 self.assertEqual(ip.user_ns['tmp'], 1)
83 83 self.assertEqual(res.success, True)
84 84 self.assertEqual(res.result, "a\nb")
85 85
86 86 def test_dont_cache_with_semicolon(self):
87 87 "Ending a line with semicolon should not cache the returned object (GH-307)"
88 88 oldlen = len(ip.user_ns['Out'])
89 89 for cell in ['1;', '1;1;']:
90 90 res = ip.run_cell(cell, store_history=True)
91 91 newlen = len(ip.user_ns['Out'])
92 92 self.assertEqual(oldlen, newlen)
93 93 self.assertIsNone(res.result)
94 94 i = 0
95 95 #also test the default caching behavior
96 96 for cell in ['1', '1;1']:
97 97 ip.run_cell(cell, store_history=True)
98 98 newlen = len(ip.user_ns['Out'])
99 99 i += 1
100 100 self.assertEqual(oldlen+i, newlen)
101 101
102 102 def test_syntax_error(self):
103 103 res = ip.run_cell("raise = 3")
104 104 self.assertIsInstance(res.error_before_exec, SyntaxError)
105 105
106 106 def test_In_variable(self):
107 107 "Verify that In variable grows with user input (GH-284)"
108 108 oldlen = len(ip.user_ns['In'])
109 109 ip.run_cell('1;', store_history=True)
110 110 newlen = len(ip.user_ns['In'])
111 111 self.assertEqual(oldlen+1, newlen)
112 112 self.assertEqual(ip.user_ns['In'][-1],'1;')
113 113
114 114 def test_magic_names_in_string(self):
115 115 ip.run_cell('a = """\n%exit\n"""')
116 116 self.assertEqual(ip.user_ns['a'], '\n%exit\n')
117 117
118 118 def test_trailing_newline(self):
119 119 """test that running !(command) does not raise a SyntaxError"""
120 120 ip.run_cell('!(true)\n', False)
121 121 ip.run_cell('!(true)\n\n\n', False)
122 122
123 123 def test_gh_597(self):
124 124 """Pretty-printing lists of objects with non-ascii reprs may cause
125 125 problems."""
126 126 class Spam(object):
127 127 def __repr__(self):
128 128 return "\xe9"*50
129 129 import IPython.core.formatters
130 130 f = IPython.core.formatters.PlainTextFormatter()
131 131 f([Spam(),Spam()])
132 132
133 133
134 134 def test_future_flags(self):
135 135 """Check that future flags are used for parsing code (gh-777)"""
136 136 ip.run_cell('from __future__ import barry_as_FLUFL')
137 137 try:
138 138 ip.run_cell('prfunc_return_val = 1 <> 2')
139 139 assert 'prfunc_return_val' in ip.user_ns
140 140 finally:
141 141 # Reset compiler flags so we don't mess up other tests.
142 142 ip.compile.reset_compiler_flags()
143 143
144 144 def test_can_pickle(self):
145 145 "Can we pickle objects defined interactively (GH-29)"
146 146 ip = get_ipython()
147 147 ip.reset()
148 148 ip.run_cell(("class Mylist(list):\n"
149 149 " def __init__(self,x=[]):\n"
150 150 " list.__init__(self,x)"))
151 151 ip.run_cell("w=Mylist([1,2,3])")
152 152
153 153 from pickle import dumps
154 154
155 155 # We need to swap in our main module - this is only necessary
156 156 # inside the test framework, because IPython puts the interactive module
157 157 # in place (but the test framework undoes this).
158 158 _main = sys.modules['__main__']
159 159 sys.modules['__main__'] = ip.user_module
160 160 try:
161 161 res = dumps(ip.user_ns["w"])
162 162 finally:
163 163 sys.modules['__main__'] = _main
164 164 self.assertTrue(isinstance(res, bytes))
165 165
166 166 def test_global_ns(self):
167 167 "Code in functions must be able to access variables outside them."
168 168 ip = get_ipython()
169 169 ip.run_cell("a = 10")
170 170 ip.run_cell(("def f(x):\n"
171 171 " return x + a"))
172 172 ip.run_cell("b = f(12)")
173 173 self.assertEqual(ip.user_ns["b"], 22)
174 174
175 175 def test_bad_custom_tb(self):
176 176 """Check that InteractiveShell is protected from bad custom exception handlers"""
177 177 ip.set_custom_exc((IOError,), lambda etype,value,tb: 1/0)
178 178 self.assertEqual(ip.custom_exceptions, (IOError,))
179 179 with tt.AssertPrints("Custom TB Handler failed", channel='stderr'):
180 180 ip.run_cell(u'raise IOError("foo")')
181 181 self.assertEqual(ip.custom_exceptions, ())
182 182
183 183 def test_bad_custom_tb_return(self):
184 184 """Check that InteractiveShell is protected from bad return types in custom exception handlers"""
185 185 ip.set_custom_exc((NameError,),lambda etype,value,tb, tb_offset=None: 1)
186 186 self.assertEqual(ip.custom_exceptions, (NameError,))
187 187 with tt.AssertPrints("Custom TB Handler failed", channel='stderr'):
188 188 ip.run_cell(u'a=abracadabra')
189 189 self.assertEqual(ip.custom_exceptions, ())
190 190
191 191 def test_drop_by_id(self):
192 192 myvars = {"a":object(), "b":object(), "c": object()}
193 193 ip.push(myvars, interactive=False)
194 194 for name in myvars:
195 195 assert name in ip.user_ns, name
196 196 assert name in ip.user_ns_hidden, name
197 197 ip.user_ns['b'] = 12
198 198 ip.drop_by_id(myvars)
199 199 for name in ["a", "c"]:
200 200 assert name not in ip.user_ns, name
201 201 assert name not in ip.user_ns_hidden, name
202 202 assert ip.user_ns['b'] == 12
203 203 ip.reset()
204 204
205 205 def test_var_expand(self):
206 206 ip.user_ns['f'] = u'Ca\xf1o'
207 207 self.assertEqual(ip.var_expand(u'echo $f'), u'echo Ca\xf1o')
208 208 self.assertEqual(ip.var_expand(u'echo {f}'), u'echo Ca\xf1o')
209 209 self.assertEqual(ip.var_expand(u'echo {f[:-1]}'), u'echo Ca\xf1')
210 210 self.assertEqual(ip.var_expand(u'echo {1*2}'), u'echo 2')
211 211
212 212 self.assertEqual(ip.var_expand(u"grep x | awk '{print $1}'"), u"grep x | awk '{print $1}'")
213 213
214 214 ip.user_ns['f'] = b'Ca\xc3\xb1o'
215 215 # This should not raise any exception:
216 216 ip.var_expand(u'echo $f')
217 217
218 218 def test_var_expand_local(self):
219 219 """Test local variable expansion in !system and %magic calls"""
220 220 # !system
221 221 ip.run_cell(
222 222 "def test():\n"
223 223 ' lvar = "ttt"\n'
224 224 " ret = !echo {lvar}\n"
225 225 " return ret[0]\n"
226 226 )
227 227 res = ip.user_ns["test"]()
228 228 self.assertIn("ttt", res)
229 229
230 230 # %magic
231 231 ip.run_cell(
232 232 "def makemacro():\n"
233 233 ' macroname = "macro_var_expand_locals"\n'
234 234 " %macro {macroname} codestr\n"
235 235 )
236 236 ip.user_ns["codestr"] = "str(12)"
237 237 ip.run_cell("makemacro()")
238 238 self.assertIn("macro_var_expand_locals", ip.user_ns)
239 239
240 240 def test_var_expand_self(self):
241 241 """Test variable expansion with the name 'self', which was failing.
242 242
243 243 See https://github.com/ipython/ipython/issues/1878#issuecomment-7698218
244 244 """
245 245 ip.run_cell(
246 246 "class cTest:\n"
247 247 ' classvar="see me"\n'
248 248 " def test(self):\n"
249 249 " res = !echo Variable: {self.classvar}\n"
250 250 " return res[0]\n"
251 251 )
252 252 self.assertIn("see me", ip.user_ns["cTest"]().test())
253 253
254 254 def test_bad_var_expand(self):
255 255 """var_expand on invalid formats shouldn't raise"""
256 256 # SyntaxError
257 257 self.assertEqual(ip.var_expand(u"{'a':5}"), u"{'a':5}")
258 258 # NameError
259 259 self.assertEqual(ip.var_expand(u"{asdf}"), u"{asdf}")
260 260 # ZeroDivisionError
261 261 self.assertEqual(ip.var_expand(u"{1/0}"), u"{1/0}")
262 262
263 263 def test_silent_postexec(self):
264 264 """run_cell(silent=True) doesn't invoke pre/post_run_cell callbacks"""
265 265 pre_explicit = mock.Mock()
266 266 pre_always = mock.Mock()
267 267 post_explicit = mock.Mock()
268 268 post_always = mock.Mock()
269 269 all_mocks = [pre_explicit, pre_always, post_explicit, post_always]
270 270
271 271 ip.events.register('pre_run_cell', pre_explicit)
272 272 ip.events.register('pre_execute', pre_always)
273 273 ip.events.register('post_run_cell', post_explicit)
274 274 ip.events.register('post_execute', post_always)
275 275
276 276 try:
277 277 ip.run_cell("1", silent=True)
278 278 assert pre_always.called
279 279 assert not pre_explicit.called
280 280 assert post_always.called
281 281 assert not post_explicit.called
282 282 # double-check that non-silent exec did what we expected
283 283 # silent to avoid
284 284 ip.run_cell("1")
285 285 assert pre_explicit.called
286 286 assert post_explicit.called
287 287 info, = pre_explicit.call_args[0]
288 288 result, = post_explicit.call_args[0]
289 289 self.assertEqual(info, result.info)
290 290 # check that post hooks are always called
291 291 [m.reset_mock() for m in all_mocks]
292 292 ip.run_cell("syntax error")
293 293 assert pre_always.called
294 294 assert pre_explicit.called
295 295 assert post_always.called
296 296 assert post_explicit.called
297 297 info, = pre_explicit.call_args[0]
298 298 result, = post_explicit.call_args[0]
299 299 self.assertEqual(info, result.info)
300 300 finally:
301 301 # remove post-exec
302 302 ip.events.unregister('pre_run_cell', pre_explicit)
303 303 ip.events.unregister('pre_execute', pre_always)
304 304 ip.events.unregister('post_run_cell', post_explicit)
305 305 ip.events.unregister('post_execute', post_always)
306 306
307 307 def test_silent_noadvance(self):
308 308 """run_cell(silent=True) doesn't advance execution_count"""
309 309 ec = ip.execution_count
310 310 # silent should force store_history=False
311 311 ip.run_cell("1", store_history=True, silent=True)
312 312
313 313 self.assertEqual(ec, ip.execution_count)
314 314 # double-check that non-silent exec did what we expected
315 315 # silent to avoid
316 316 ip.run_cell("1", store_history=True)
317 317 self.assertEqual(ec+1, ip.execution_count)
318 318
319 319 def test_silent_nodisplayhook(self):
320 320 """run_cell(silent=True) doesn't trigger displayhook"""
321 321 d = dict(called=False)
322 322
323 323 trap = ip.display_trap
324 324 save_hook = trap.hook
325 325
326 326 def failing_hook(*args, **kwargs):
327 327 d['called'] = True
328 328
329 329 try:
330 330 trap.hook = failing_hook
331 331 res = ip.run_cell("1", silent=True)
332 332 self.assertFalse(d['called'])
333 333 self.assertIsNone(res.result)
334 334 # double-check that non-silent exec did what we expected
335 335 # silent to avoid
336 336 ip.run_cell("1")
337 337 self.assertTrue(d['called'])
338 338 finally:
339 339 trap.hook = save_hook
340 340
341 341 def test_ofind_line_magic(self):
342 342 from IPython.core.magic import register_line_magic
343 343
344 344 @register_line_magic
345 345 def lmagic(line):
346 346 "A line magic"
347 347
348 348 # Get info on line magic
349 349 lfind = ip._ofind("lmagic")
350 350 info = dict(
351 351 found=True,
352 352 isalias=False,
353 353 ismagic=True,
354 354 namespace="IPython internal",
355 355 obj=lmagic,
356 356 parent=None,
357 357 )
358 358 self.assertEqual(lfind, info)
359 359
360 360 def test_ofind_cell_magic(self):
361 361 from IPython.core.magic import register_cell_magic
362 362
363 363 @register_cell_magic
364 364 def cmagic(line, cell):
365 365 "A cell magic"
366 366
367 367 # Get info on cell magic
368 368 find = ip._ofind("cmagic")
369 369 info = dict(
370 370 found=True,
371 371 isalias=False,
372 372 ismagic=True,
373 373 namespace="IPython internal",
374 374 obj=cmagic,
375 375 parent=None,
376 376 )
377 377 self.assertEqual(find, info)
378 378
379 379 def test_ofind_property_with_error(self):
380 380 class A(object):
381 381 @property
382 382 def foo(self):
383 383 raise NotImplementedError()
384 384 a = A()
385 385
386 386 found = ip._ofind('a.foo', [('locals', locals())])
387 387 info = dict(found=True, isalias=False, ismagic=False,
388 388 namespace='locals', obj=A.foo, parent=a)
389 389 self.assertEqual(found, info)
390 390
391 391 def test_ofind_multiple_attribute_lookups(self):
392 392 class A(object):
393 393 @property
394 394 def foo(self):
395 395 raise NotImplementedError()
396 396
397 397 a = A()
398 398 a.a = A()
399 399 a.a.a = A()
400 400
401 401 found = ip._ofind('a.a.a.foo', [('locals', locals())])
402 402 info = dict(found=True, isalias=False, ismagic=False,
403 403 namespace='locals', obj=A.foo, parent=a.a.a)
404 404 self.assertEqual(found, info)
405 405
406 406 def test_ofind_slotted_attributes(self):
407 407 class A(object):
408 408 __slots__ = ['foo']
409 409 def __init__(self):
410 410 self.foo = 'bar'
411 411
412 412 a = A()
413 413 found = ip._ofind('a.foo', [('locals', locals())])
414 414 info = dict(found=True, isalias=False, ismagic=False,
415 415 namespace='locals', obj=a.foo, parent=a)
416 416 self.assertEqual(found, info)
417 417
418 418 found = ip._ofind('a.bar', [('locals', locals())])
419 419 info = dict(found=False, isalias=False, ismagic=False,
420 420 namespace=None, obj=None, parent=a)
421 421 self.assertEqual(found, info)
422 422
423 423 def test_ofind_prefers_property_to_instance_level_attribute(self):
424 424 class A(object):
425 425 @property
426 426 def foo(self):
427 427 return 'bar'
428 428 a = A()
429 429 a.__dict__["foo"] = "baz"
430 430 self.assertEqual(a.foo, "bar")
431 431 found = ip._ofind("a.foo", [("locals", locals())])
432 432 self.assertIs(found["obj"], A.foo)
433 433
434 434 def test_custom_syntaxerror_exception(self):
435 435 called = []
436 436 def my_handler(shell, etype, value, tb, tb_offset=None):
437 437 called.append(etype)
438 438 shell.showtraceback((etype, value, tb), tb_offset=tb_offset)
439 439
440 440 ip.set_custom_exc((SyntaxError,), my_handler)
441 441 try:
442 442 ip.run_cell("1f")
443 443 # Check that this was called, and only once.
444 444 self.assertEqual(called, [SyntaxError])
445 445 finally:
446 446 # Reset the custom exception hook
447 447 ip.set_custom_exc((), None)
448 448
449 449 def test_custom_exception(self):
450 450 called = []
451 451 def my_handler(shell, etype, value, tb, tb_offset=None):
452 452 called.append(etype)
453 453 shell.showtraceback((etype, value, tb), tb_offset=tb_offset)
454 454
455 455 ip.set_custom_exc((ValueError,), my_handler)
456 456 try:
457 457 res = ip.run_cell("raise ValueError('test')")
458 458 # Check that this was called, and only once.
459 459 self.assertEqual(called, [ValueError])
460 460 # Check that the error is on the result object
461 461 self.assertIsInstance(res.error_in_exec, ValueError)
462 462 finally:
463 463 # Reset the custom exception hook
464 464 ip.set_custom_exc((), None)
465 465
466 466 @mock.patch("builtins.print")
467 467 def test_showtraceback_with_surrogates(self, mocked_print):
468 468 values = []
469 469
470 470 def mock_print_func(value, sep=" ", end="\n", file=sys.stdout, flush=False):
471 471 values.append(value)
472 472 if value == chr(0xD8FF):
473 473 raise UnicodeEncodeError("utf-8", chr(0xD8FF), 0, 1, "")
474 474
475 475 # mock builtins.print
476 476 mocked_print.side_effect = mock_print_func
477 477
478 478 # ip._showtraceback() is replaced in globalipapp.py.
479 479 # Call original method to test.
480 480 interactiveshell.InteractiveShell._showtraceback(ip, None, None, chr(0xD8FF))
481 481
482 482 self.assertEqual(mocked_print.call_count, 2)
483 483 self.assertEqual(values, [chr(0xD8FF), "\\ud8ff"])
484 484
485 485 def test_mktempfile(self):
486 486 filename = ip.mktempfile()
487 487 # Check that we can open the file again on Windows
488 488 with open(filename, "w", encoding="utf-8") as f:
489 489 f.write("abc")
490 490
491 491 filename = ip.mktempfile(data="blah")
492 492 with open(filename, "r", encoding="utf-8") as f:
493 493 self.assertEqual(f.read(), "blah")
494 494
495 495 def test_new_main_mod(self):
496 496 # Smoketest to check that this accepts a unicode module name
497 497 name = u'jiefmw'
498 498 mod = ip.new_main_mod(u'%s.py' % name, name)
499 499 self.assertEqual(mod.__name__, name)
500 500
501 501 def test_get_exception_only(self):
502 502 try:
503 503 raise KeyboardInterrupt
504 504 except KeyboardInterrupt:
505 505 msg = ip.get_exception_only()
506 506 self.assertEqual(msg, 'KeyboardInterrupt\n')
507 507
508 508 try:
509 509 raise DerivedInterrupt("foo")
510 510 except KeyboardInterrupt:
511 511 msg = ip.get_exception_only()
512 512 self.assertEqual(msg, 'IPython.core.tests.test_interactiveshell.DerivedInterrupt: foo\n')
513 513
514 514 def test_inspect_text(self):
515 515 ip.run_cell('a = 5')
516 516 text = ip.object_inspect_text('a')
517 517 self.assertIsInstance(text, str)
518 518
519 519 def test_last_execution_result(self):
520 520 """ Check that last execution result gets set correctly (GH-10702) """
521 521 result = ip.run_cell('a = 5; a')
522 522 self.assertTrue(ip.last_execution_succeeded)
523 523 self.assertEqual(ip.last_execution_result.result, 5)
524 524
525 525 result = ip.run_cell('a = x_invalid_id_x')
526 526 self.assertFalse(ip.last_execution_succeeded)
527 527 self.assertFalse(ip.last_execution_result.success)
528 528 self.assertIsInstance(ip.last_execution_result.error_in_exec, NameError)
529 529
530 530 def test_reset_aliasing(self):
531 531 """ Check that standard posix aliases work after %reset. """
532 532 if os.name != 'posix':
533 533 return
534 534
535 535 ip.reset()
536 536 for cmd in ('clear', 'more', 'less', 'man'):
537 537 res = ip.run_cell('%' + cmd)
538 538 self.assertEqual(res.success, True)
539 539
540 540
541 541 class TestSafeExecfileNonAsciiPath(unittest.TestCase):
542 542
543 543 @onlyif_unicode_paths
544 544 def setUp(self):
545 545 self.BASETESTDIR = tempfile.mkdtemp()
546 546 self.TESTDIR = join(self.BASETESTDIR, u"Γ₯Àâ")
547 547 os.mkdir(self.TESTDIR)
548 548 with open(
549 549 join(self.TESTDIR, u"Γ₯Àâtestscript.py"), "w", encoding="utf-8"
550 550 ) as sfile:
551 551 sfile.write("pass\n")
552 552 self.oldpath = os.getcwd()
553 553 os.chdir(self.TESTDIR)
554 554 self.fname = u"Γ₯Àâtestscript.py"
555 555
556 556 def tearDown(self):
557 557 os.chdir(self.oldpath)
558 558 shutil.rmtree(self.BASETESTDIR)
559 559
560 560 @onlyif_unicode_paths
561 561 def test_1(self):
562 562 """Test safe_execfile with non-ascii path
563 563 """
564 564 ip.safe_execfile(self.fname, {}, raise_exceptions=True)
565 565
566 566 class ExitCodeChecks(tt.TempFileMixin):
567 567
568 568 def setUp(self):
569 569 self.system = ip.system_raw
570 570
571 571 def test_exit_code_ok(self):
572 572 self.system('exit 0')
573 573 self.assertEqual(ip.user_ns['_exit_code'], 0)
574 574
575 575 def test_exit_code_error(self):
576 576 self.system('exit 1')
577 577 self.assertEqual(ip.user_ns['_exit_code'], 1)
578 578
579 579 @skipif(not hasattr(signal, 'SIGALRM'))
580 580 def test_exit_code_signal(self):
581 581 self.mktmp("import signal, time\n"
582 582 "signal.setitimer(signal.ITIMER_REAL, 0.1)\n"
583 583 "time.sleep(1)\n")
584 584 self.system("%s %s" % (sys.executable, self.fname))
585 585 self.assertEqual(ip.user_ns['_exit_code'], -signal.SIGALRM)
586 586
587 587 @onlyif_cmds_exist("csh")
588 588 def test_exit_code_signal_csh(self):
589 589 SHELL = os.environ.get('SHELL', None)
590 590 os.environ['SHELL'] = find_cmd("csh")
591 591 try:
592 592 self.test_exit_code_signal()
593 593 finally:
594 594 if SHELL is not None:
595 595 os.environ['SHELL'] = SHELL
596 596 else:
597 597 del os.environ['SHELL']
598 598
599 599
600 600 class TestSystemRaw(ExitCodeChecks):
601 601
602 602 def setUp(self):
603 603 super().setUp()
604 604 self.system = ip.system_raw
605 605
606 606 @onlyif_unicode_paths
607 607 def test_1(self):
608 608 """Test system_raw with non-ascii cmd
609 609 """
610 610 cmd = u'''python -c "'Γ₯Àâ'" '''
611 611 ip.system_raw(cmd)
612 612
613 613 @mock.patch('subprocess.call', side_effect=KeyboardInterrupt)
614 614 @mock.patch('os.system', side_effect=KeyboardInterrupt)
615 615 def test_control_c(self, *mocks):
616 616 try:
617 617 self.system("sleep 1 # wont happen")
618 618 except KeyboardInterrupt:
619 619 self.fail(
620 620 "system call should intercept "
621 621 "keyboard interrupt from subprocess.call"
622 622 )
623 623 self.assertEqual(ip.user_ns["_exit_code"], -signal.SIGINT)
624 624
625 625 def test_magic_warnings(self):
626 for magic_cmd in ("ls", "pip", "conda", "cd"):
626 for magic_cmd in ("pip", "conda", "cd"):
627 627 with self.assertWarnsRegex(Warning, "You executed the system command"):
628 628 ip.system_raw(magic_cmd)
629 629
630 630 # TODO: Exit codes are currently ignored on Windows.
631 631 class TestSystemPipedExitCode(ExitCodeChecks):
632 632
633 633 def setUp(self):
634 634 super().setUp()
635 635 self.system = ip.system_piped
636 636
637 637 @skip_win32
638 638 def test_exit_code_ok(self):
639 639 ExitCodeChecks.test_exit_code_ok(self)
640 640
641 641 @skip_win32
642 642 def test_exit_code_error(self):
643 643 ExitCodeChecks.test_exit_code_error(self)
644 644
645 645 @skip_win32
646 646 def test_exit_code_signal(self):
647 647 ExitCodeChecks.test_exit_code_signal(self)
648 648
649 649 class TestModules(tt.TempFileMixin):
650 650 def test_extraneous_loads(self):
651 651 """Test we're not loading modules on startup that we shouldn't.
652 652 """
653 653 self.mktmp("import sys\n"
654 654 "print('numpy' in sys.modules)\n"
655 655 "print('ipyparallel' in sys.modules)\n"
656 656 "print('ipykernel' in sys.modules)\n"
657 657 )
658 658 out = "False\nFalse\nFalse\n"
659 659 tt.ipexec_validate(self.fname, out)
660 660
661 661 class Negator(ast.NodeTransformer):
662 662 """Negates all number literals in an AST."""
663 663
664 664 # for python 3.7 and earlier
665 665 def visit_Num(self, node):
666 666 node.n = -node.n
667 667 return node
668 668
669 669 # for python 3.8+
670 670 def visit_Constant(self, node):
671 671 if isinstance(node.value, int):
672 672 return self.visit_Num(node)
673 673 return node
674 674
675 675 class TestAstTransform(unittest.TestCase):
676 676 def setUp(self):
677 677 self.negator = Negator()
678 678 ip.ast_transformers.append(self.negator)
679 679
680 680 def tearDown(self):
681 681 ip.ast_transformers.remove(self.negator)
682 682
683 683 def test_run_cell(self):
684 684 with tt.AssertPrints('-34'):
685 685 ip.run_cell('print (12 + 22)')
686 686
687 687 # A named reference to a number shouldn't be transformed.
688 688 ip.user_ns['n'] = 55
689 689 with tt.AssertNotPrints('-55'):
690 690 ip.run_cell('print (n)')
691 691
692 692 def test_timeit(self):
693 693 called = set()
694 694 def f(x):
695 695 called.add(x)
696 696 ip.push({'f':f})
697 697
698 698 with tt.AssertPrints("std. dev. of"):
699 699 ip.run_line_magic("timeit", "-n1 f(1)")
700 700 self.assertEqual(called, {-1})
701 701 called.clear()
702 702
703 703 with tt.AssertPrints("std. dev. of"):
704 704 ip.run_cell_magic("timeit", "-n1 f(2)", "f(3)")
705 705 self.assertEqual(called, {-2, -3})
706 706
707 707 def test_time(self):
708 708 called = []
709 709 def f(x):
710 710 called.append(x)
711 711 ip.push({'f':f})
712 712
713 713 # Test with an expression
714 714 with tt.AssertPrints("Wall time: "):
715 715 ip.run_line_magic("time", "f(5+9)")
716 716 self.assertEqual(called, [-14])
717 717 called[:] = []
718 718
719 719 # Test with a statement (different code path)
720 720 with tt.AssertPrints("Wall time: "):
721 721 ip.run_line_magic("time", "a = f(-3 + -2)")
722 722 self.assertEqual(called, [5])
723 723
724 724 def test_macro(self):
725 725 ip.push({'a':10})
726 726 # The AST transformation makes this do a+=-1
727 727 ip.define_macro("amacro", "a+=1\nprint(a)")
728 728
729 729 with tt.AssertPrints("9"):
730 730 ip.run_cell("amacro")
731 731 with tt.AssertPrints("8"):
732 732 ip.run_cell("amacro")
733 733
734 734 class TestMiscTransform(unittest.TestCase):
735 735
736 736
737 737 def test_transform_only_once(self):
738 738 cleanup = 0
739 739 line_t = 0
740 740 def count_cleanup(lines):
741 741 nonlocal cleanup
742 742 cleanup += 1
743 743 return lines
744 744
745 745 def count_line_t(lines):
746 746 nonlocal line_t
747 747 line_t += 1
748 748 return lines
749 749
750 750 ip.input_transformer_manager.cleanup_transforms.append(count_cleanup)
751 751 ip.input_transformer_manager.line_transforms.append(count_line_t)
752 752
753 753 ip.run_cell('1')
754 754
755 755 assert cleanup == 1
756 756 assert line_t == 1
757 757
758 758 class IntegerWrapper(ast.NodeTransformer):
759 759 """Wraps all integers in a call to Integer()"""
760 760
761 761 # for Python 3.7 and earlier
762 762
763 763 # for Python 3.7 and earlier
764 764 def visit_Num(self, node):
765 765 if isinstance(node.n, int):
766 766 return ast.Call(func=ast.Name(id='Integer', ctx=ast.Load()),
767 767 args=[node], keywords=[])
768 768 return node
769 769
770 770 # For Python 3.8+
771 771 def visit_Constant(self, node):
772 772 if isinstance(node.value, int):
773 773 return self.visit_Num(node)
774 774 return node
775 775
776 776
777 777 class TestAstTransform2(unittest.TestCase):
778 778 def setUp(self):
779 779 self.intwrapper = IntegerWrapper()
780 780 ip.ast_transformers.append(self.intwrapper)
781 781
782 782 self.calls = []
783 783 def Integer(*args):
784 784 self.calls.append(args)
785 785 return args
786 786 ip.push({"Integer": Integer})
787 787
788 788 def tearDown(self):
789 789 ip.ast_transformers.remove(self.intwrapper)
790 790 del ip.user_ns['Integer']
791 791
792 792 def test_run_cell(self):
793 793 ip.run_cell("n = 2")
794 794 self.assertEqual(self.calls, [(2,)])
795 795
796 796 # This shouldn't throw an error
797 797 ip.run_cell("o = 2.0")
798 798 self.assertEqual(ip.user_ns['o'], 2.0)
799 799
800 800 def test_timeit(self):
801 801 called = set()
802 802 def f(x):
803 803 called.add(x)
804 804 ip.push({'f':f})
805 805
806 806 with tt.AssertPrints("std. dev. of"):
807 807 ip.run_line_magic("timeit", "-n1 f(1)")
808 808 self.assertEqual(called, {(1,)})
809 809 called.clear()
810 810
811 811 with tt.AssertPrints("std. dev. of"):
812 812 ip.run_cell_magic("timeit", "-n1 f(2)", "f(3)")
813 813 self.assertEqual(called, {(2,), (3,)})
814 814
815 815 class ErrorTransformer(ast.NodeTransformer):
816 816 """Throws an error when it sees a number."""
817 817
818 818 # for Python 3.7 and earlier
819 819 def visit_Num(self, node):
820 820 raise ValueError("test")
821 821
822 822 # for Python 3.8+
823 823 def visit_Constant(self, node):
824 824 if isinstance(node.value, int):
825 825 return self.visit_Num(node)
826 826 return node
827 827
828 828
829 829 class TestAstTransformError(unittest.TestCase):
830 830 def test_unregistering(self):
831 831 err_transformer = ErrorTransformer()
832 832 ip.ast_transformers.append(err_transformer)
833 833
834 834 with self.assertWarnsRegex(UserWarning, "It will be unregistered"):
835 835 ip.run_cell("1 + 2")
836 836
837 837 # This should have been removed.
838 838 self.assertNotIn(err_transformer, ip.ast_transformers)
839 839
840 840
841 841 class StringRejector(ast.NodeTransformer):
842 842 """Throws an InputRejected when it sees a string literal.
843 843
844 844 Used to verify that NodeTransformers can signal that a piece of code should
845 845 not be executed by throwing an InputRejected.
846 846 """
847 847
848 848 #for python 3.7 and earlier
849 849 def visit_Str(self, node):
850 850 raise InputRejected("test")
851 851
852 852 # 3.8 only
853 853 def visit_Constant(self, node):
854 854 if isinstance(node.value, str):
855 855 raise InputRejected("test")
856 856 return node
857 857
858 858
859 859 class TestAstTransformInputRejection(unittest.TestCase):
860 860
861 861 def setUp(self):
862 862 self.transformer = StringRejector()
863 863 ip.ast_transformers.append(self.transformer)
864 864
865 865 def tearDown(self):
866 866 ip.ast_transformers.remove(self.transformer)
867 867
868 868 def test_input_rejection(self):
869 869 """Check that NodeTransformers can reject input."""
870 870
871 871 expect_exception_tb = tt.AssertPrints("InputRejected: test")
872 872 expect_no_cell_output = tt.AssertNotPrints("'unsafe'", suppress=False)
873 873
874 874 # Run the same check twice to verify that the transformer is not
875 875 # disabled after raising.
876 876 with expect_exception_tb, expect_no_cell_output:
877 877 ip.run_cell("'unsafe'")
878 878
879 879 with expect_exception_tb, expect_no_cell_output:
880 880 res = ip.run_cell("'unsafe'")
881 881
882 882 self.assertIsInstance(res.error_before_exec, InputRejected)
883 883
884 884 def test__IPYTHON__():
885 885 # This shouldn't raise a NameError, that's all
886 886 __IPYTHON__
887 887
888 888
889 889 class DummyRepr(object):
890 890 def __repr__(self):
891 891 return "DummyRepr"
892 892
893 893 def _repr_html_(self):
894 894 return "<b>dummy</b>"
895 895
896 896 def _repr_javascript_(self):
897 897 return "console.log('hi');", {'key': 'value'}
898 898
899 899
900 900 def test_user_variables():
901 901 # enable all formatters
902 902 ip.display_formatter.active_types = ip.display_formatter.format_types
903 903
904 904 ip.user_ns['dummy'] = d = DummyRepr()
905 905 keys = {'dummy', 'doesnotexist'}
906 906 r = ip.user_expressions({ key:key for key in keys})
907 907
908 908 assert keys == set(r.keys())
909 909 dummy = r["dummy"]
910 910 assert {"status", "data", "metadata"} == set(dummy.keys())
911 911 assert dummy["status"] == "ok"
912 912 data = dummy["data"]
913 913 metadata = dummy["metadata"]
914 914 assert data.get("text/html") == d._repr_html_()
915 915 js, jsmd = d._repr_javascript_()
916 916 assert data.get("application/javascript") == js
917 917 assert metadata.get("application/javascript") == jsmd
918 918
919 919 dne = r["doesnotexist"]
920 920 assert dne["status"] == "error"
921 921 assert dne["ename"] == "NameError"
922 922
923 923 # back to text only
924 924 ip.display_formatter.active_types = ['text/plain']
925 925
926 926 def test_user_expression():
927 927 # enable all formatters
928 928 ip.display_formatter.active_types = ip.display_formatter.format_types
929 929 query = {
930 930 'a' : '1 + 2',
931 931 'b' : '1/0',
932 932 }
933 933 r = ip.user_expressions(query)
934 934 import pprint
935 935 pprint.pprint(r)
936 936 assert set(r.keys()) == set(query.keys())
937 937 a = r["a"]
938 938 assert {"status", "data", "metadata"} == set(a.keys())
939 939 assert a["status"] == "ok"
940 940 data = a["data"]
941 941 metadata = a["metadata"]
942 942 assert data.get("text/plain") == "3"
943 943
944 944 b = r["b"]
945 945 assert b["status"] == "error"
946 946 assert b["ename"] == "ZeroDivisionError"
947 947
948 948 # back to text only
949 949 ip.display_formatter.active_types = ['text/plain']
950 950
951 951
952 952 class TestSyntaxErrorTransformer(unittest.TestCase):
953 953 """Check that SyntaxError raised by an input transformer is handled by run_cell()"""
954 954
955 955 @staticmethod
956 956 def transformer(lines):
957 957 for line in lines:
958 958 pos = line.find('syntaxerror')
959 959 if pos >= 0:
960 960 e = SyntaxError('input contains "syntaxerror"')
961 961 e.text = line
962 962 e.offset = pos + 1
963 963 raise e
964 964 return lines
965 965
966 966 def setUp(self):
967 967 ip.input_transformers_post.append(self.transformer)
968 968
969 969 def tearDown(self):
970 970 ip.input_transformers_post.remove(self.transformer)
971 971
972 972 def test_syntaxerror_input_transformer(self):
973 973 with tt.AssertPrints('1234'):
974 974 ip.run_cell('1234')
975 975 with tt.AssertPrints('SyntaxError: invalid syntax'):
976 976 ip.run_cell('1 2 3') # plain python syntax error
977 977 with tt.AssertPrints('SyntaxError: input contains "syntaxerror"'):
978 978 ip.run_cell('2345 # syntaxerror') # input transformer syntax error
979 979 with tt.AssertPrints('3456'):
980 980 ip.run_cell('3456')
981 981
982 982
983 983 class TestWarningSuppression(unittest.TestCase):
984 984 def test_warning_suppression(self):
985 985 ip.run_cell("import warnings")
986 986 try:
987 987 with self.assertWarnsRegex(UserWarning, "asdf"):
988 988 ip.run_cell("warnings.warn('asdf')")
989 989 # Here's the real test -- if we run that again, we should get the
990 990 # warning again. Traditionally, each warning was only issued once per
991 991 # IPython session (approximately), even if the user typed in new and
992 992 # different code that should have also triggered the warning, leading
993 993 # to much confusion.
994 994 with self.assertWarnsRegex(UserWarning, "asdf"):
995 995 ip.run_cell("warnings.warn('asdf')")
996 996 finally:
997 997 ip.run_cell("del warnings")
998 998
999 999
1000 1000 def test_deprecation_warning(self):
1001 1001 ip.run_cell("""
1002 1002 import warnings
1003 1003 def wrn():
1004 1004 warnings.warn(
1005 1005 "I AM A WARNING",
1006 1006 DeprecationWarning
1007 1007 )
1008 1008 """)
1009 1009 try:
1010 1010 with self.assertWarnsRegex(DeprecationWarning, "I AM A WARNING"):
1011 1011 ip.run_cell("wrn()")
1012 1012 finally:
1013 1013 ip.run_cell("del warnings")
1014 1014 ip.run_cell("del wrn")
1015 1015
1016 1016
1017 1017 class TestImportNoDeprecate(tt.TempFileMixin):
1018 1018
1019 1019 def setUp(self):
1020 1020 """Make a valid python temp file."""
1021 1021 self.mktmp("""
1022 1022 import warnings
1023 1023 def wrn():
1024 1024 warnings.warn(
1025 1025 "I AM A WARNING",
1026 1026 DeprecationWarning
1027 1027 )
1028 1028 """)
1029 1029 super().setUp()
1030 1030
1031 1031 def test_no_dep(self):
1032 1032 """
1033 1033 No deprecation warning should be raised from imported functions
1034 1034 """
1035 1035 ip.run_cell("from {} import wrn".format(self.fname))
1036 1036
1037 1037 with tt.AssertNotPrints("I AM A WARNING"):
1038 1038 ip.run_cell("wrn()")
1039 1039 ip.run_cell("del wrn")
1040 1040
1041 1041
1042 1042 def test_custom_exc_count():
1043 1043 hook = mock.Mock(return_value=None)
1044 1044 ip.set_custom_exc((SyntaxError,), hook)
1045 1045 before = ip.execution_count
1046 1046 ip.run_cell("def foo()", store_history=True)
1047 1047 # restore default excepthook
1048 1048 ip.set_custom_exc((), None)
1049 1049 assert hook.call_count == 1
1050 1050 assert ip.execution_count == before + 1
1051 1051
1052 1052
1053 1053 def test_run_cell_async():
1054 1054 ip.run_cell("import asyncio")
1055 1055 coro = ip.run_cell_async("await asyncio.sleep(0.01)\n5")
1056 1056 assert asyncio.iscoroutine(coro)
1057 1057 loop = asyncio.new_event_loop()
1058 1058 result = loop.run_until_complete(coro)
1059 1059 assert isinstance(result, interactiveshell.ExecutionResult)
1060 1060 assert result.result == 5
1061 1061
1062 1062
1063 1063 def test_run_cell_await():
1064 1064 ip.run_cell("import asyncio")
1065 1065 result = ip.run_cell("await asyncio.sleep(0.01); 10")
1066 1066 assert ip.user_ns["_"] == 10
1067 1067
1068 1068
1069 1069 def test_run_cell_asyncio_run():
1070 1070 ip.run_cell("import asyncio")
1071 1071 result = ip.run_cell("await asyncio.sleep(0.01); 1")
1072 1072 assert ip.user_ns["_"] == 1
1073 1073 result = ip.run_cell("asyncio.run(asyncio.sleep(0.01)); 2")
1074 1074 assert ip.user_ns["_"] == 2
1075 1075 result = ip.run_cell("await asyncio.sleep(0.01); 3")
1076 1076 assert ip.user_ns["_"] == 3
1077 1077
1078 1078
1079 1079 def test_should_run_async():
1080 1080 assert not ip.should_run_async("a = 5")
1081 1081 assert ip.should_run_async("await x")
1082 1082 assert ip.should_run_async("import asyncio; await asyncio.sleep(1)")
1083 1083
1084 1084
1085 1085 def test_set_custom_completer():
1086 1086 num_completers = len(ip.Completer.matchers)
1087 1087
1088 1088 def foo(*args, **kwargs):
1089 1089 return "I'm a completer!"
1090 1090
1091 1091 ip.set_custom_completer(foo, 0)
1092 1092
1093 1093 # check that we've really added a new completer
1094 1094 assert len(ip.Completer.matchers) == num_completers + 1
1095 1095
1096 1096 # check that the first completer is the function we defined
1097 1097 assert ip.Completer.matchers[0]() == "I'm a completer!"
1098 1098
1099 1099 # clean up
1100 1100 ip.Completer.custom_matchers.pop()
General Comments 0
You need to be logged in to leave comments. Login now