##// END OF EJS Templates
Merge pull request #13534 from sabjohnso/eliminate_ls_warnings...
Matthias Bussonnier -
r27534:91a1ed9e merge
parent child Browse files
Show More
@@ -1,3698 +1,3693 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 new_path = p.readlink()
778 778 if not new_path.is_absolute():
779 779 new_path = p.parent / new_path
780 780 p = new_path
781 781 paths.append(p)
782 782
783 783 # In Cygwin paths like "c:\..." and '\cygdrive\c\...' are possible
784 784 if p_venv.parts[1] == "cygdrive":
785 785 drive_name = p_venv.parts[2]
786 786 p_venv = (drive_name + ":/") / Path(*p_venv.parts[3:])
787 787
788 788 if any(p_venv == p.parents[1] for p in paths):
789 789 # Our exe is inside or has access to the virtualenv, don't need to do anything.
790 790 return
791 791
792 792 if sys.platform == "win32":
793 793 virtual_env = str(Path(os.environ["VIRTUAL_ENV"], "Lib", "site-packages"))
794 794 else:
795 795 virtual_env_path = Path(
796 796 os.environ["VIRTUAL_ENV"], "lib", "python{}.{}", "site-packages"
797 797 )
798 798 p_ver = sys.version_info[:2]
799 799
800 800 # Predict version from py[thon]-x.x in the $VIRTUAL_ENV
801 801 re_m = re.search(r"\bpy(?:thon)?([23])\.(\d+)\b", os.environ["VIRTUAL_ENV"])
802 802 if re_m:
803 803 predicted_path = Path(str(virtual_env_path).format(*re_m.groups()))
804 804 if predicted_path.exists():
805 805 p_ver = re_m.groups()
806 806
807 807 virtual_env = str(virtual_env_path).format(*p_ver)
808 808
809 809 warn(
810 810 "Attempting to work in a virtualenv. If you encounter problems, "
811 811 "please install IPython inside the virtualenv."
812 812 )
813 813 import site
814 814 sys.path.insert(0, virtual_env)
815 815 site.addsitedir(virtual_env)
816 816
817 817 #-------------------------------------------------------------------------
818 818 # Things related to injections into the sys module
819 819 #-------------------------------------------------------------------------
820 820
821 821 def save_sys_module_state(self):
822 822 """Save the state of hooks in the sys module.
823 823
824 824 This has to be called after self.user_module is created.
825 825 """
826 826 self._orig_sys_module_state = {'stdin': sys.stdin,
827 827 'stdout': sys.stdout,
828 828 'stderr': sys.stderr,
829 829 'excepthook': sys.excepthook}
830 830 self._orig_sys_modules_main_name = self.user_module.__name__
831 831 self._orig_sys_modules_main_mod = sys.modules.get(self.user_module.__name__)
832 832
833 833 def restore_sys_module_state(self):
834 834 """Restore the state of the sys module."""
835 835 try:
836 836 for k, v in self._orig_sys_module_state.items():
837 837 setattr(sys, k, v)
838 838 except AttributeError:
839 839 pass
840 840 # Reset what what done in self.init_sys_modules
841 841 if self._orig_sys_modules_main_mod is not None:
842 842 sys.modules[self._orig_sys_modules_main_name] = self._orig_sys_modules_main_mod
843 843
844 844 #-------------------------------------------------------------------------
845 845 # Things related to the banner
846 846 #-------------------------------------------------------------------------
847 847
848 848 @property
849 849 def banner(self):
850 850 banner = self.banner1
851 851 if self.profile and self.profile != 'default':
852 852 banner += '\nIPython profile: %s\n' % self.profile
853 853 if self.banner2:
854 854 banner += '\n' + self.banner2
855 855 return banner
856 856
857 857 def show_banner(self, banner=None):
858 858 if banner is None:
859 859 banner = self.banner
860 860 sys.stdout.write(banner)
861 861
862 862 #-------------------------------------------------------------------------
863 863 # Things related to hooks
864 864 #-------------------------------------------------------------------------
865 865
866 866 def init_hooks(self):
867 867 # hooks holds pointers used for user-side customizations
868 868 self.hooks = Struct()
869 869
870 870 self.strdispatchers = {}
871 871
872 872 # Set all default hooks, defined in the IPython.hooks module.
873 873 hooks = IPython.core.hooks
874 874 for hook_name in hooks.__all__:
875 875 # default hooks have priority 100, i.e. low; user hooks should have
876 876 # 0-100 priority
877 877 self.set_hook(hook_name, getattr(hooks, hook_name), 100)
878 878
879 879 if self.display_page:
880 880 self.set_hook('show_in_pager', page.as_hook(page.display_page), 90)
881 881
882 882 def set_hook(self, name, hook, priority=50, str_key=None, re_key=None):
883 883 """set_hook(name,hook) -> sets an internal IPython hook.
884 884
885 885 IPython exposes some of its internal API as user-modifiable hooks. By
886 886 adding your function to one of these hooks, you can modify IPython's
887 887 behavior to call at runtime your own routines."""
888 888
889 889 # At some point in the future, this should validate the hook before it
890 890 # accepts it. Probably at least check that the hook takes the number
891 891 # of args it's supposed to.
892 892
893 893 f = types.MethodType(hook,self)
894 894
895 895 # check if the hook is for strdispatcher first
896 896 if str_key is not None:
897 897 sdp = self.strdispatchers.get(name, StrDispatch())
898 898 sdp.add_s(str_key, f, priority )
899 899 self.strdispatchers[name] = sdp
900 900 return
901 901 if re_key is not None:
902 902 sdp = self.strdispatchers.get(name, StrDispatch())
903 903 sdp.add_re(re.compile(re_key), f, priority )
904 904 self.strdispatchers[name] = sdp
905 905 return
906 906
907 907 dp = getattr(self.hooks, name, None)
908 908 if name not in IPython.core.hooks.__all__:
909 909 print("Warning! Hook '%s' is not one of %s" % \
910 910 (name, IPython.core.hooks.__all__ ))
911 911
912 912 if name in IPython.core.hooks.deprecated:
913 913 alternative = IPython.core.hooks.deprecated[name]
914 914 raise ValueError(
915 915 "Hook {} has been deprecated since IPython 5.0. Use {} instead.".format(
916 916 name, alternative
917 917 )
918 918 )
919 919
920 920 if not dp:
921 921 dp = IPython.core.hooks.CommandChainDispatcher()
922 922
923 923 try:
924 924 dp.add(f,priority)
925 925 except AttributeError:
926 926 # it was not commandchain, plain old func - replace
927 927 dp = f
928 928
929 929 setattr(self.hooks,name, dp)
930 930
931 931 #-------------------------------------------------------------------------
932 932 # Things related to events
933 933 #-------------------------------------------------------------------------
934 934
935 935 def init_events(self):
936 936 self.events = EventManager(self, available_events)
937 937
938 938 self.events.register("pre_execute", self._clear_warning_registry)
939 939
940 940 def register_post_execute(self, func):
941 941 """DEPRECATED: Use ip.events.register('post_run_cell', func)
942 942
943 943 Register a function for calling after code execution.
944 944 """
945 945 raise ValueError(
946 946 "ip.register_post_execute is deprecated since IPython 1.0, use "
947 947 "ip.events.register('post_run_cell', func) instead."
948 948 )
949 949
950 950 def _clear_warning_registry(self):
951 951 # clear the warning registry, so that different code blocks with
952 952 # overlapping line number ranges don't cause spurious suppression of
953 953 # warnings (see gh-6611 for details)
954 954 if "__warningregistry__" in self.user_global_ns:
955 955 del self.user_global_ns["__warningregistry__"]
956 956
957 957 #-------------------------------------------------------------------------
958 958 # Things related to the "main" module
959 959 #-------------------------------------------------------------------------
960 960
961 961 def new_main_mod(self, filename, modname):
962 962 """Return a new 'main' module object for user code execution.
963 963
964 964 ``filename`` should be the path of the script which will be run in the
965 965 module. Requests with the same filename will get the same module, with
966 966 its namespace cleared.
967 967
968 968 ``modname`` should be the module name - normally either '__main__' or
969 969 the basename of the file without the extension.
970 970
971 971 When scripts are executed via %run, we must keep a reference to their
972 972 __main__ module around so that Python doesn't
973 973 clear it, rendering references to module globals useless.
974 974
975 975 This method keeps said reference in a private dict, keyed by the
976 976 absolute path of the script. This way, for multiple executions of the
977 977 same script we only keep one copy of the namespace (the last one),
978 978 thus preventing memory leaks from old references while allowing the
979 979 objects from the last execution to be accessible.
980 980 """
981 981 filename = os.path.abspath(filename)
982 982 try:
983 983 main_mod = self._main_mod_cache[filename]
984 984 except KeyError:
985 985 main_mod = self._main_mod_cache[filename] = types.ModuleType(
986 986 modname,
987 987 doc="Module created for script run in IPython")
988 988 else:
989 989 main_mod.__dict__.clear()
990 990 main_mod.__name__ = modname
991 991
992 992 main_mod.__file__ = filename
993 993 # It seems pydoc (and perhaps others) needs any module instance to
994 994 # implement a __nonzero__ method
995 995 main_mod.__nonzero__ = lambda : True
996 996
997 997 return main_mod
998 998
999 999 def clear_main_mod_cache(self):
1000 1000 """Clear the cache of main modules.
1001 1001
1002 1002 Mainly for use by utilities like %reset.
1003 1003
1004 1004 Examples
1005 1005 --------
1006 1006 In [15]: import IPython
1007 1007
1008 1008 In [16]: m = _ip.new_main_mod(IPython.__file__, 'IPython')
1009 1009
1010 1010 In [17]: len(_ip._main_mod_cache) > 0
1011 1011 Out[17]: True
1012 1012
1013 1013 In [18]: _ip.clear_main_mod_cache()
1014 1014
1015 1015 In [19]: len(_ip._main_mod_cache) == 0
1016 1016 Out[19]: True
1017 1017 """
1018 1018 self._main_mod_cache.clear()
1019 1019
1020 1020 #-------------------------------------------------------------------------
1021 1021 # Things related to debugging
1022 1022 #-------------------------------------------------------------------------
1023 1023
1024 1024 def init_pdb(self):
1025 1025 # Set calling of pdb on exceptions
1026 1026 # self.call_pdb is a property
1027 1027 self.call_pdb = self.pdb
1028 1028
1029 1029 def _get_call_pdb(self):
1030 1030 return self._call_pdb
1031 1031
1032 1032 def _set_call_pdb(self,val):
1033 1033
1034 1034 if val not in (0,1,False,True):
1035 1035 raise ValueError('new call_pdb value must be boolean')
1036 1036
1037 1037 # store value in instance
1038 1038 self._call_pdb = val
1039 1039
1040 1040 # notify the actual exception handlers
1041 1041 self.InteractiveTB.call_pdb = val
1042 1042
1043 1043 call_pdb = property(_get_call_pdb,_set_call_pdb,None,
1044 1044 'Control auto-activation of pdb at exceptions')
1045 1045
1046 1046 def debugger(self,force=False):
1047 1047 """Call the pdb debugger.
1048 1048
1049 1049 Keywords:
1050 1050
1051 1051 - force(False): by default, this routine checks the instance call_pdb
1052 1052 flag and does not actually invoke the debugger if the flag is false.
1053 1053 The 'force' option forces the debugger to activate even if the flag
1054 1054 is false.
1055 1055 """
1056 1056
1057 1057 if not (force or self.call_pdb):
1058 1058 return
1059 1059
1060 1060 if not hasattr(sys,'last_traceback'):
1061 1061 error('No traceback has been produced, nothing to debug.')
1062 1062 return
1063 1063
1064 1064 self.InteractiveTB.debugger(force=True)
1065 1065
1066 1066 #-------------------------------------------------------------------------
1067 1067 # Things related to IPython's various namespaces
1068 1068 #-------------------------------------------------------------------------
1069 1069 default_user_namespaces = True
1070 1070
1071 1071 def init_create_namespaces(self, user_module=None, user_ns=None):
1072 1072 # Create the namespace where the user will operate. user_ns is
1073 1073 # normally the only one used, and it is passed to the exec calls as
1074 1074 # the locals argument. But we do carry a user_global_ns namespace
1075 1075 # given as the exec 'globals' argument, This is useful in embedding
1076 1076 # situations where the ipython shell opens in a context where the
1077 1077 # distinction between locals and globals is meaningful. For
1078 1078 # non-embedded contexts, it is just the same object as the user_ns dict.
1079 1079
1080 1080 # FIXME. For some strange reason, __builtins__ is showing up at user
1081 1081 # level as a dict instead of a module. This is a manual fix, but I
1082 1082 # should really track down where the problem is coming from. Alex
1083 1083 # Schmolck reported this problem first.
1084 1084
1085 1085 # A useful post by Alex Martelli on this topic:
1086 1086 # Re: inconsistent value from __builtins__
1087 1087 # Von: Alex Martelli <aleaxit@yahoo.com>
1088 1088 # Datum: Freitag 01 Oktober 2004 04:45:34 nachmittags/abends
1089 1089 # Gruppen: comp.lang.python
1090 1090
1091 1091 # Michael Hohn <hohn@hooknose.lbl.gov> wrote:
1092 1092 # > >>> print type(builtin_check.get_global_binding('__builtins__'))
1093 1093 # > <type 'dict'>
1094 1094 # > >>> print type(__builtins__)
1095 1095 # > <type 'module'>
1096 1096 # > Is this difference in return value intentional?
1097 1097
1098 1098 # Well, it's documented that '__builtins__' can be either a dictionary
1099 1099 # or a module, and it's been that way for a long time. Whether it's
1100 1100 # intentional (or sensible), I don't know. In any case, the idea is
1101 1101 # that if you need to access the built-in namespace directly, you
1102 1102 # should start with "import __builtin__" (note, no 's') which will
1103 1103 # definitely give you a module. Yeah, it's somewhat confusing:-(.
1104 1104
1105 1105 # These routines return a properly built module and dict as needed by
1106 1106 # the rest of the code, and can also be used by extension writers to
1107 1107 # generate properly initialized namespaces.
1108 1108 if (user_ns is not None) or (user_module is not None):
1109 1109 self.default_user_namespaces = False
1110 1110 self.user_module, self.user_ns = self.prepare_user_module(user_module, user_ns)
1111 1111
1112 1112 # A record of hidden variables we have added to the user namespace, so
1113 1113 # we can list later only variables defined in actual interactive use.
1114 1114 self.user_ns_hidden = {}
1115 1115
1116 1116 # Now that FakeModule produces a real module, we've run into a nasty
1117 1117 # problem: after script execution (via %run), the module where the user
1118 1118 # code ran is deleted. Now that this object is a true module (needed
1119 1119 # so doctest and other tools work correctly), the Python module
1120 1120 # teardown mechanism runs over it, and sets to None every variable
1121 1121 # present in that module. Top-level references to objects from the
1122 1122 # script survive, because the user_ns is updated with them. However,
1123 1123 # calling functions defined in the script that use other things from
1124 1124 # the script will fail, because the function's closure had references
1125 1125 # to the original objects, which are now all None. So we must protect
1126 1126 # these modules from deletion by keeping a cache.
1127 1127 #
1128 1128 # To avoid keeping stale modules around (we only need the one from the
1129 1129 # last run), we use a dict keyed with the full path to the script, so
1130 1130 # only the last version of the module is held in the cache. Note,
1131 1131 # however, that we must cache the module *namespace contents* (their
1132 1132 # __dict__). Because if we try to cache the actual modules, old ones
1133 1133 # (uncached) could be destroyed while still holding references (such as
1134 1134 # those held by GUI objects that tend to be long-lived)>
1135 1135 #
1136 1136 # The %reset command will flush this cache. See the cache_main_mod()
1137 1137 # and clear_main_mod_cache() methods for details on use.
1138 1138
1139 1139 # This is the cache used for 'main' namespaces
1140 1140 self._main_mod_cache = {}
1141 1141
1142 1142 # A table holding all the namespaces IPython deals with, so that
1143 1143 # introspection facilities can search easily.
1144 1144 self.ns_table = {'user_global':self.user_module.__dict__,
1145 1145 'user_local':self.user_ns,
1146 1146 'builtin':builtin_mod.__dict__
1147 1147 }
1148 1148
1149 1149 @property
1150 1150 def user_global_ns(self):
1151 1151 return self.user_module.__dict__
1152 1152
1153 1153 def prepare_user_module(self, user_module=None, user_ns=None):
1154 1154 """Prepare the module and namespace in which user code will be run.
1155 1155
1156 1156 When IPython is started normally, both parameters are None: a new module
1157 1157 is created automatically, and its __dict__ used as the namespace.
1158 1158
1159 1159 If only user_module is provided, its __dict__ is used as the namespace.
1160 1160 If only user_ns is provided, a dummy module is created, and user_ns
1161 1161 becomes the global namespace. If both are provided (as they may be
1162 1162 when embedding), user_ns is the local namespace, and user_module
1163 1163 provides the global namespace.
1164 1164
1165 1165 Parameters
1166 1166 ----------
1167 1167 user_module : module, optional
1168 1168 The current user module in which IPython is being run. If None,
1169 1169 a clean module will be created.
1170 1170 user_ns : dict, optional
1171 1171 A namespace in which to run interactive commands.
1172 1172
1173 1173 Returns
1174 1174 -------
1175 1175 A tuple of user_module and user_ns, each properly initialised.
1176 1176 """
1177 1177 if user_module is None and user_ns is not None:
1178 1178 user_ns.setdefault("__name__", "__main__")
1179 1179 user_module = DummyMod()
1180 1180 user_module.__dict__ = user_ns
1181 1181
1182 1182 if user_module is None:
1183 1183 user_module = types.ModuleType("__main__",
1184 1184 doc="Automatically created module for IPython interactive environment")
1185 1185
1186 1186 # We must ensure that __builtin__ (without the final 's') is always
1187 1187 # available and pointing to the __builtin__ *module*. For more details:
1188 1188 # http://mail.python.org/pipermail/python-dev/2001-April/014068.html
1189 1189 user_module.__dict__.setdefault('__builtin__', builtin_mod)
1190 1190 user_module.__dict__.setdefault('__builtins__', builtin_mod)
1191 1191
1192 1192 if user_ns is None:
1193 1193 user_ns = user_module.__dict__
1194 1194
1195 1195 return user_module, user_ns
1196 1196
1197 1197 def init_sys_modules(self):
1198 1198 # We need to insert into sys.modules something that looks like a
1199 1199 # module but which accesses the IPython namespace, for shelve and
1200 1200 # pickle to work interactively. Normally they rely on getting
1201 1201 # everything out of __main__, but for embedding purposes each IPython
1202 1202 # instance has its own private namespace, so we can't go shoving
1203 1203 # everything into __main__.
1204 1204
1205 1205 # note, however, that we should only do this for non-embedded
1206 1206 # ipythons, which really mimic the __main__.__dict__ with their own
1207 1207 # namespace. Embedded instances, on the other hand, should not do
1208 1208 # this because they need to manage the user local/global namespaces
1209 1209 # only, but they live within a 'normal' __main__ (meaning, they
1210 1210 # shouldn't overtake the execution environment of the script they're
1211 1211 # embedded in).
1212 1212
1213 1213 # This is overridden in the InteractiveShellEmbed subclass to a no-op.
1214 1214 main_name = self.user_module.__name__
1215 1215 sys.modules[main_name] = self.user_module
1216 1216
1217 1217 def init_user_ns(self):
1218 1218 """Initialize all user-visible namespaces to their minimum defaults.
1219 1219
1220 1220 Certain history lists are also initialized here, as they effectively
1221 1221 act as user namespaces.
1222 1222
1223 1223 Notes
1224 1224 -----
1225 1225 All data structures here are only filled in, they are NOT reset by this
1226 1226 method. If they were not empty before, data will simply be added to
1227 1227 them.
1228 1228 """
1229 1229 # This function works in two parts: first we put a few things in
1230 1230 # user_ns, and we sync that contents into user_ns_hidden so that these
1231 1231 # initial variables aren't shown by %who. After the sync, we add the
1232 1232 # rest of what we *do* want the user to see with %who even on a new
1233 1233 # session (probably nothing, so they really only see their own stuff)
1234 1234
1235 1235 # The user dict must *always* have a __builtin__ reference to the
1236 1236 # Python standard __builtin__ namespace, which must be imported.
1237 1237 # This is so that certain operations in prompt evaluation can be
1238 1238 # reliably executed with builtins. Note that we can NOT use
1239 1239 # __builtins__ (note the 's'), because that can either be a dict or a
1240 1240 # module, and can even mutate at runtime, depending on the context
1241 1241 # (Python makes no guarantees on it). In contrast, __builtin__ is
1242 1242 # always a module object, though it must be explicitly imported.
1243 1243
1244 1244 # For more details:
1245 1245 # http://mail.python.org/pipermail/python-dev/2001-April/014068.html
1246 1246 ns = {}
1247 1247
1248 1248 # make global variables for user access to the histories
1249 1249 ns['_ih'] = self.history_manager.input_hist_parsed
1250 1250 ns['_oh'] = self.history_manager.output_hist
1251 1251 ns['_dh'] = self.history_manager.dir_hist
1252 1252
1253 1253 # user aliases to input and output histories. These shouldn't show up
1254 1254 # in %who, as they can have very large reprs.
1255 1255 ns['In'] = self.history_manager.input_hist_parsed
1256 1256 ns['Out'] = self.history_manager.output_hist
1257 1257
1258 1258 # Store myself as the public api!!!
1259 1259 ns['get_ipython'] = self.get_ipython
1260 1260
1261 1261 ns['exit'] = self.exiter
1262 1262 ns['quit'] = self.exiter
1263 1263
1264 1264 # Sync what we've added so far to user_ns_hidden so these aren't seen
1265 1265 # by %who
1266 1266 self.user_ns_hidden.update(ns)
1267 1267
1268 1268 # Anything put into ns now would show up in %who. Think twice before
1269 1269 # putting anything here, as we really want %who to show the user their
1270 1270 # stuff, not our variables.
1271 1271
1272 1272 # Finally, update the real user's namespace
1273 1273 self.user_ns.update(ns)
1274 1274
1275 1275 @property
1276 1276 def all_ns_refs(self):
1277 1277 """Get a list of references to all the namespace dictionaries in which
1278 1278 IPython might store a user-created object.
1279 1279
1280 1280 Note that this does not include the displayhook, which also caches
1281 1281 objects from the output."""
1282 1282 return [self.user_ns, self.user_global_ns, self.user_ns_hidden] + \
1283 1283 [m.__dict__ for m in self._main_mod_cache.values()]
1284 1284
1285 1285 def reset(self, new_session=True, aggressive=False):
1286 1286 """Clear all internal namespaces, and attempt to release references to
1287 1287 user objects.
1288 1288
1289 1289 If new_session is True, a new history session will be opened.
1290 1290 """
1291 1291 # Clear histories
1292 1292 self.history_manager.reset(new_session)
1293 1293 # Reset counter used to index all histories
1294 1294 if new_session:
1295 1295 self.execution_count = 1
1296 1296
1297 1297 # Reset last execution result
1298 1298 self.last_execution_succeeded = True
1299 1299 self.last_execution_result = None
1300 1300
1301 1301 # Flush cached output items
1302 1302 if self.displayhook.do_full_cache:
1303 1303 self.displayhook.flush()
1304 1304
1305 1305 # The main execution namespaces must be cleared very carefully,
1306 1306 # skipping the deletion of the builtin-related keys, because doing so
1307 1307 # would cause errors in many object's __del__ methods.
1308 1308 if self.user_ns is not self.user_global_ns:
1309 1309 self.user_ns.clear()
1310 1310 ns = self.user_global_ns
1311 1311 drop_keys = set(ns.keys())
1312 1312 drop_keys.discard('__builtin__')
1313 1313 drop_keys.discard('__builtins__')
1314 1314 drop_keys.discard('__name__')
1315 1315 for k in drop_keys:
1316 1316 del ns[k]
1317 1317
1318 1318 self.user_ns_hidden.clear()
1319 1319
1320 1320 # Restore the user namespaces to minimal usability
1321 1321 self.init_user_ns()
1322 1322 if aggressive and not hasattr(self, "_sys_modules_keys"):
1323 1323 print("Cannot restore sys.module, no snapshot")
1324 1324 elif aggressive:
1325 1325 print("culling sys module...")
1326 1326 current_keys = set(sys.modules.keys())
1327 1327 for k in current_keys - self._sys_modules_keys:
1328 1328 if k.startswith("multiprocessing"):
1329 1329 continue
1330 1330 del sys.modules[k]
1331 1331
1332 1332 # Restore the default and user aliases
1333 1333 self.alias_manager.clear_aliases()
1334 1334 self.alias_manager.init_aliases()
1335 1335
1336 1336 # Now define aliases that only make sense on the terminal, because they
1337 1337 # need direct access to the console in a way that we can't emulate in
1338 1338 # GUI or web frontend
1339 1339 if os.name == 'posix':
1340 1340 for cmd in ('clear', 'more', 'less', 'man'):
1341 1341 if cmd not in self.magics_manager.magics['line']:
1342 1342 self.alias_manager.soft_define_alias(cmd, cmd)
1343 1343
1344 1344 # Flush the private list of module references kept for script
1345 1345 # execution protection
1346 1346 self.clear_main_mod_cache()
1347 1347
1348 1348 def del_var(self, varname, by_name=False):
1349 1349 """Delete a variable from the various namespaces, so that, as
1350 1350 far as possible, we're not keeping any hidden references to it.
1351 1351
1352 1352 Parameters
1353 1353 ----------
1354 1354 varname : str
1355 1355 The name of the variable to delete.
1356 1356 by_name : bool
1357 1357 If True, delete variables with the given name in each
1358 1358 namespace. If False (default), find the variable in the user
1359 1359 namespace, and delete references to it.
1360 1360 """
1361 1361 if varname in ('__builtin__', '__builtins__'):
1362 1362 raise ValueError("Refusing to delete %s" % varname)
1363 1363
1364 1364 ns_refs = self.all_ns_refs
1365 1365
1366 1366 if by_name: # Delete by name
1367 1367 for ns in ns_refs:
1368 1368 try:
1369 1369 del ns[varname]
1370 1370 except KeyError:
1371 1371 pass
1372 1372 else: # Delete by object
1373 1373 try:
1374 1374 obj = self.user_ns[varname]
1375 1375 except KeyError as e:
1376 1376 raise NameError("name '%s' is not defined" % varname) from e
1377 1377 # Also check in output history
1378 1378 ns_refs.append(self.history_manager.output_hist)
1379 1379 for ns in ns_refs:
1380 1380 to_delete = [n for n, o in ns.items() if o is obj]
1381 1381 for name in to_delete:
1382 1382 del ns[name]
1383 1383
1384 1384 # Ensure it is removed from the last execution result
1385 1385 if self.last_execution_result.result is obj:
1386 1386 self.last_execution_result = None
1387 1387
1388 1388 # displayhook keeps extra references, but not in a dictionary
1389 1389 for name in ('_', '__', '___'):
1390 1390 if getattr(self.displayhook, name) is obj:
1391 1391 setattr(self.displayhook, name, None)
1392 1392
1393 1393 def reset_selective(self, regex=None):
1394 1394 """Clear selective variables from internal namespaces based on a
1395 1395 specified regular expression.
1396 1396
1397 1397 Parameters
1398 1398 ----------
1399 1399 regex : string or compiled pattern, optional
1400 1400 A regular expression pattern that will be used in searching
1401 1401 variable names in the users namespaces.
1402 1402 """
1403 1403 if regex is not None:
1404 1404 try:
1405 1405 m = re.compile(regex)
1406 1406 except TypeError as e:
1407 1407 raise TypeError('regex must be a string or compiled pattern') from e
1408 1408 # Search for keys in each namespace that match the given regex
1409 1409 # If a match is found, delete the key/value pair.
1410 1410 for ns in self.all_ns_refs:
1411 1411 for var in ns:
1412 1412 if m.search(var):
1413 1413 del ns[var]
1414 1414
1415 1415 def push(self, variables, interactive=True):
1416 1416 """Inject a group of variables into the IPython user namespace.
1417 1417
1418 1418 Parameters
1419 1419 ----------
1420 1420 variables : dict, str or list/tuple of str
1421 1421 The variables to inject into the user's namespace. If a dict, a
1422 1422 simple update is done. If a str, the string is assumed to have
1423 1423 variable names separated by spaces. A list/tuple of str can also
1424 1424 be used to give the variable names. If just the variable names are
1425 1425 give (list/tuple/str) then the variable values looked up in the
1426 1426 callers frame.
1427 1427 interactive : bool
1428 1428 If True (default), the variables will be listed with the ``who``
1429 1429 magic.
1430 1430 """
1431 1431 vdict = None
1432 1432
1433 1433 # We need a dict of name/value pairs to do namespace updates.
1434 1434 if isinstance(variables, dict):
1435 1435 vdict = variables
1436 1436 elif isinstance(variables, (str, list, tuple)):
1437 1437 if isinstance(variables, str):
1438 1438 vlist = variables.split()
1439 1439 else:
1440 1440 vlist = variables
1441 1441 vdict = {}
1442 1442 cf = sys._getframe(1)
1443 1443 for name in vlist:
1444 1444 try:
1445 1445 vdict[name] = eval(name, cf.f_globals, cf.f_locals)
1446 1446 except:
1447 1447 print('Could not get variable %s from %s' %
1448 1448 (name,cf.f_code.co_name))
1449 1449 else:
1450 1450 raise ValueError('variables must be a dict/str/list/tuple')
1451 1451
1452 1452 # Propagate variables to user namespace
1453 1453 self.user_ns.update(vdict)
1454 1454
1455 1455 # And configure interactive visibility
1456 1456 user_ns_hidden = self.user_ns_hidden
1457 1457 if interactive:
1458 1458 for name in vdict:
1459 1459 user_ns_hidden.pop(name, None)
1460 1460 else:
1461 1461 user_ns_hidden.update(vdict)
1462 1462
1463 1463 def drop_by_id(self, variables):
1464 1464 """Remove a dict of variables from the user namespace, if they are the
1465 1465 same as the values in the dictionary.
1466 1466
1467 1467 This is intended for use by extensions: variables that they've added can
1468 1468 be taken back out if they are unloaded, without removing any that the
1469 1469 user has overwritten.
1470 1470
1471 1471 Parameters
1472 1472 ----------
1473 1473 variables : dict
1474 1474 A dictionary mapping object names (as strings) to the objects.
1475 1475 """
1476 1476 for name, obj in variables.items():
1477 1477 if name in self.user_ns and self.user_ns[name] is obj:
1478 1478 del self.user_ns[name]
1479 1479 self.user_ns_hidden.pop(name, None)
1480 1480
1481 1481 #-------------------------------------------------------------------------
1482 1482 # Things related to object introspection
1483 1483 #-------------------------------------------------------------------------
1484 1484
1485 1485 def _ofind(self, oname, namespaces=None):
1486 1486 """Find an object in the available namespaces.
1487 1487
1488 1488 self._ofind(oname) -> dict with keys: found,obj,ospace,ismagic
1489 1489
1490 1490 Has special code to detect magic functions.
1491 1491 """
1492 1492 oname = oname.strip()
1493 1493 if not oname.startswith(ESC_MAGIC) and \
1494 1494 not oname.startswith(ESC_MAGIC2) and \
1495 1495 not all(a.isidentifier() for a in oname.split(".")):
1496 1496 return {'found': False}
1497 1497
1498 1498 if namespaces is None:
1499 1499 # Namespaces to search in:
1500 1500 # Put them in a list. The order is important so that we
1501 1501 # find things in the same order that Python finds them.
1502 1502 namespaces = [ ('Interactive', self.user_ns),
1503 1503 ('Interactive (global)', self.user_global_ns),
1504 1504 ('Python builtin', builtin_mod.__dict__),
1505 1505 ]
1506 1506
1507 1507 ismagic = False
1508 1508 isalias = False
1509 1509 found = False
1510 1510 ospace = None
1511 1511 parent = None
1512 1512 obj = None
1513 1513
1514 1514
1515 1515 # Look for the given name by splitting it in parts. If the head is
1516 1516 # found, then we look for all the remaining parts as members, and only
1517 1517 # declare success if we can find them all.
1518 1518 oname_parts = oname.split('.')
1519 1519 oname_head, oname_rest = oname_parts[0],oname_parts[1:]
1520 1520 for nsname,ns in namespaces:
1521 1521 try:
1522 1522 obj = ns[oname_head]
1523 1523 except KeyError:
1524 1524 continue
1525 1525 else:
1526 1526 for idx, part in enumerate(oname_rest):
1527 1527 try:
1528 1528 parent = obj
1529 1529 # The last part is looked up in a special way to avoid
1530 1530 # descriptor invocation as it may raise or have side
1531 1531 # effects.
1532 1532 if idx == len(oname_rest) - 1:
1533 1533 obj = self._getattr_property(obj, part)
1534 1534 else:
1535 1535 obj = getattr(obj, part)
1536 1536 except:
1537 1537 # Blanket except b/c some badly implemented objects
1538 1538 # allow __getattr__ to raise exceptions other than
1539 1539 # AttributeError, which then crashes IPython.
1540 1540 break
1541 1541 else:
1542 1542 # If we finish the for loop (no break), we got all members
1543 1543 found = True
1544 1544 ospace = nsname
1545 1545 break # namespace loop
1546 1546
1547 1547 # Try to see if it's magic
1548 1548 if not found:
1549 1549 obj = None
1550 1550 if oname.startswith(ESC_MAGIC2):
1551 1551 oname = oname.lstrip(ESC_MAGIC2)
1552 1552 obj = self.find_cell_magic(oname)
1553 1553 elif oname.startswith(ESC_MAGIC):
1554 1554 oname = oname.lstrip(ESC_MAGIC)
1555 1555 obj = self.find_line_magic(oname)
1556 1556 else:
1557 1557 # search without prefix, so run? will find %run?
1558 1558 obj = self.find_line_magic(oname)
1559 1559 if obj is None:
1560 1560 obj = self.find_cell_magic(oname)
1561 1561 if obj is not None:
1562 1562 found = True
1563 1563 ospace = 'IPython internal'
1564 1564 ismagic = True
1565 1565 isalias = isinstance(obj, Alias)
1566 1566
1567 1567 # Last try: special-case some literals like '', [], {}, etc:
1568 1568 if not found and oname_head in ["''",'""','[]','{}','()']:
1569 1569 obj = eval(oname_head)
1570 1570 found = True
1571 1571 ospace = 'Interactive'
1572 1572
1573 1573 return {
1574 1574 'obj':obj,
1575 1575 'found':found,
1576 1576 'parent':parent,
1577 1577 'ismagic':ismagic,
1578 1578 'isalias':isalias,
1579 1579 'namespace':ospace
1580 1580 }
1581 1581
1582 1582 @staticmethod
1583 1583 def _getattr_property(obj, attrname):
1584 1584 """Property-aware getattr to use in object finding.
1585 1585
1586 1586 If attrname represents a property, return it unevaluated (in case it has
1587 1587 side effects or raises an error.
1588 1588
1589 1589 """
1590 1590 if not isinstance(obj, type):
1591 1591 try:
1592 1592 # `getattr(type(obj), attrname)` is not guaranteed to return
1593 1593 # `obj`, but does so for property:
1594 1594 #
1595 1595 # property.__get__(self, None, cls) -> self
1596 1596 #
1597 1597 # The universal alternative is to traverse the mro manually
1598 1598 # searching for attrname in class dicts.
1599 1599 attr = getattr(type(obj), attrname)
1600 1600 except AttributeError:
1601 1601 pass
1602 1602 else:
1603 1603 # This relies on the fact that data descriptors (with both
1604 1604 # __get__ & __set__ magic methods) take precedence over
1605 1605 # instance-level attributes:
1606 1606 #
1607 1607 # class A(object):
1608 1608 # @property
1609 1609 # def foobar(self): return 123
1610 1610 # a = A()
1611 1611 # a.__dict__['foobar'] = 345
1612 1612 # a.foobar # == 123
1613 1613 #
1614 1614 # So, a property may be returned right away.
1615 1615 if isinstance(attr, property):
1616 1616 return attr
1617 1617
1618 1618 # Nothing helped, fall back.
1619 1619 return getattr(obj, attrname)
1620 1620
1621 1621 def _object_find(self, oname, namespaces=None):
1622 1622 """Find an object and return a struct with info about it."""
1623 1623 return Struct(self._ofind(oname, namespaces))
1624 1624
1625 1625 def _inspect(self, meth, oname, namespaces=None, **kw):
1626 1626 """Generic interface to the inspector system.
1627 1627
1628 1628 This function is meant to be called by pdef, pdoc & friends.
1629 1629 """
1630 1630 info = self._object_find(oname, namespaces)
1631 1631 docformat = (
1632 1632 sphinxify(self.object_inspect(oname)) if self.sphinxify_docstring else None
1633 1633 )
1634 1634 if info.found:
1635 1635 pmethod = getattr(self.inspector, meth)
1636 1636 # TODO: only apply format_screen to the plain/text repr of the mime
1637 1637 # bundle.
1638 1638 formatter = format_screen if info.ismagic else docformat
1639 1639 if meth == 'pdoc':
1640 1640 pmethod(info.obj, oname, formatter)
1641 1641 elif meth == 'pinfo':
1642 1642 pmethod(
1643 1643 info.obj,
1644 1644 oname,
1645 1645 formatter,
1646 1646 info,
1647 1647 enable_html_pager=self.enable_html_pager,
1648 1648 **kw,
1649 1649 )
1650 1650 else:
1651 1651 pmethod(info.obj, oname)
1652 1652 else:
1653 1653 print('Object `%s` not found.' % oname)
1654 1654 return 'not found' # so callers can take other action
1655 1655
1656 1656 def object_inspect(self, oname, detail_level=0):
1657 1657 """Get object info about oname"""
1658 1658 with self.builtin_trap:
1659 1659 info = self._object_find(oname)
1660 1660 if info.found:
1661 1661 return self.inspector.info(info.obj, oname, info=info,
1662 1662 detail_level=detail_level
1663 1663 )
1664 1664 else:
1665 1665 return oinspect.object_info(name=oname, found=False)
1666 1666
1667 1667 def object_inspect_text(self, oname, detail_level=0):
1668 1668 """Get object info as formatted text"""
1669 1669 return self.object_inspect_mime(oname, detail_level)['text/plain']
1670 1670
1671 1671 def object_inspect_mime(self, oname, detail_level=0, omit_sections=()):
1672 1672 """Get object info as a mimebundle of formatted representations.
1673 1673
1674 1674 A mimebundle is a dictionary, keyed by mime-type.
1675 1675 It must always have the key `'text/plain'`.
1676 1676 """
1677 1677 with self.builtin_trap:
1678 1678 info = self._object_find(oname)
1679 1679 if info.found:
1680 1680 docformat = (
1681 1681 sphinxify(self.object_inspect(oname))
1682 1682 if self.sphinxify_docstring
1683 1683 else None
1684 1684 )
1685 1685 return self.inspector._get_info(
1686 1686 info.obj,
1687 1687 oname,
1688 1688 info=info,
1689 1689 detail_level=detail_level,
1690 1690 formatter=docformat,
1691 1691 omit_sections=omit_sections,
1692 1692 )
1693 1693 else:
1694 1694 raise KeyError(oname)
1695 1695
1696 1696 #-------------------------------------------------------------------------
1697 1697 # Things related to history management
1698 1698 #-------------------------------------------------------------------------
1699 1699
1700 1700 def init_history(self):
1701 1701 """Sets up the command history, and starts regular autosaves."""
1702 1702 self.history_manager = HistoryManager(shell=self, parent=self)
1703 1703 self.configurables.append(self.history_manager)
1704 1704
1705 1705 #-------------------------------------------------------------------------
1706 1706 # Things related to exception handling and tracebacks (not debugging)
1707 1707 #-------------------------------------------------------------------------
1708 1708
1709 1709 debugger_cls = InterruptiblePdb
1710 1710
1711 1711 def init_traceback_handlers(self, custom_exceptions):
1712 1712 # Syntax error handler.
1713 1713 self.SyntaxTB = ultratb.SyntaxTB(color_scheme='NoColor', parent=self)
1714 1714
1715 1715 # The interactive one is initialized with an offset, meaning we always
1716 1716 # want to remove the topmost item in the traceback, which is our own
1717 1717 # internal code. Valid modes: ['Plain','Context','Verbose','Minimal']
1718 1718 self.InteractiveTB = ultratb.AutoFormattedTB(mode = 'Plain',
1719 1719 color_scheme='NoColor',
1720 1720 tb_offset = 1,
1721 1721 check_cache=check_linecache_ipython,
1722 1722 debugger_cls=self.debugger_cls, parent=self)
1723 1723
1724 1724 # The instance will store a pointer to the system-wide exception hook,
1725 1725 # so that runtime code (such as magics) can access it. This is because
1726 1726 # during the read-eval loop, it may get temporarily overwritten.
1727 1727 self.sys_excepthook = sys.excepthook
1728 1728
1729 1729 # and add any custom exception handlers the user may have specified
1730 1730 self.set_custom_exc(*custom_exceptions)
1731 1731
1732 1732 # Set the exception mode
1733 1733 self.InteractiveTB.set_mode(mode=self.xmode)
1734 1734
1735 1735 def set_custom_exc(self, exc_tuple, handler):
1736 1736 """set_custom_exc(exc_tuple, handler)
1737 1737
1738 1738 Set a custom exception handler, which will be called if any of the
1739 1739 exceptions in exc_tuple occur in the mainloop (specifically, in the
1740 1740 run_code() method).
1741 1741
1742 1742 Parameters
1743 1743 ----------
1744 1744 exc_tuple : tuple of exception classes
1745 1745 A *tuple* of exception classes, for which to call the defined
1746 1746 handler. It is very important that you use a tuple, and NOT A
1747 1747 LIST here, because of the way Python's except statement works. If
1748 1748 you only want to trap a single exception, use a singleton tuple::
1749 1749
1750 1750 exc_tuple == (MyCustomException,)
1751 1751
1752 1752 handler : callable
1753 1753 handler must have the following signature::
1754 1754
1755 1755 def my_handler(self, etype, value, tb, tb_offset=None):
1756 1756 ...
1757 1757 return structured_traceback
1758 1758
1759 1759 Your handler must return a structured traceback (a list of strings),
1760 1760 or None.
1761 1761
1762 1762 This will be made into an instance method (via types.MethodType)
1763 1763 of IPython itself, and it will be called if any of the exceptions
1764 1764 listed in the exc_tuple are caught. If the handler is None, an
1765 1765 internal basic one is used, which just prints basic info.
1766 1766
1767 1767 To protect IPython from crashes, if your handler ever raises an
1768 1768 exception or returns an invalid result, it will be immediately
1769 1769 disabled.
1770 1770
1771 1771 Notes
1772 1772 -----
1773 1773 WARNING: by putting in your own exception handler into IPython's main
1774 1774 execution loop, you run a very good chance of nasty crashes. This
1775 1775 facility should only be used if you really know what you are doing.
1776 1776 """
1777 1777
1778 1778 if not isinstance(exc_tuple, tuple):
1779 1779 raise TypeError("The custom exceptions must be given as a tuple.")
1780 1780
1781 1781 def dummy_handler(self, etype, value, tb, tb_offset=None):
1782 1782 print('*** Simple custom exception handler ***')
1783 1783 print('Exception type :', etype)
1784 1784 print('Exception value:', value)
1785 1785 print('Traceback :', tb)
1786 1786
1787 1787 def validate_stb(stb):
1788 1788 """validate structured traceback return type
1789 1789
1790 1790 return type of CustomTB *should* be a list of strings, but allow
1791 1791 single strings or None, which are harmless.
1792 1792
1793 1793 This function will *always* return a list of strings,
1794 1794 and will raise a TypeError if stb is inappropriate.
1795 1795 """
1796 1796 msg = "CustomTB must return list of strings, not %r" % stb
1797 1797 if stb is None:
1798 1798 return []
1799 1799 elif isinstance(stb, str):
1800 1800 return [stb]
1801 1801 elif not isinstance(stb, list):
1802 1802 raise TypeError(msg)
1803 1803 # it's a list
1804 1804 for line in stb:
1805 1805 # check every element
1806 1806 if not isinstance(line, str):
1807 1807 raise TypeError(msg)
1808 1808 return stb
1809 1809
1810 1810 if handler is None:
1811 1811 wrapped = dummy_handler
1812 1812 else:
1813 1813 def wrapped(self,etype,value,tb,tb_offset=None):
1814 1814 """wrap CustomTB handler, to protect IPython from user code
1815 1815
1816 1816 This makes it harder (but not impossible) for custom exception
1817 1817 handlers to crash IPython.
1818 1818 """
1819 1819 try:
1820 1820 stb = handler(self,etype,value,tb,tb_offset=tb_offset)
1821 1821 return validate_stb(stb)
1822 1822 except:
1823 1823 # clear custom handler immediately
1824 1824 self.set_custom_exc((), None)
1825 1825 print("Custom TB Handler failed, unregistering", file=sys.stderr)
1826 1826 # show the exception in handler first
1827 1827 stb = self.InteractiveTB.structured_traceback(*sys.exc_info())
1828 1828 print(self.InteractiveTB.stb2text(stb))
1829 1829 print("The original exception:")
1830 1830 stb = self.InteractiveTB.structured_traceback(
1831 1831 (etype,value,tb), tb_offset=tb_offset
1832 1832 )
1833 1833 return stb
1834 1834
1835 1835 self.CustomTB = types.MethodType(wrapped,self)
1836 1836 self.custom_exceptions = exc_tuple
1837 1837
1838 1838 def excepthook(self, etype, value, tb):
1839 1839 """One more defense for GUI apps that call sys.excepthook.
1840 1840
1841 1841 GUI frameworks like wxPython trap exceptions and call
1842 1842 sys.excepthook themselves. I guess this is a feature that
1843 1843 enables them to keep running after exceptions that would
1844 1844 otherwise kill their mainloop. This is a bother for IPython
1845 1845 which expects to catch all of the program exceptions with a try:
1846 1846 except: statement.
1847 1847
1848 1848 Normally, IPython sets sys.excepthook to a CrashHandler instance, so if
1849 1849 any app directly invokes sys.excepthook, it will look to the user like
1850 1850 IPython crashed. In order to work around this, we can disable the
1851 1851 CrashHandler and replace it with this excepthook instead, which prints a
1852 1852 regular traceback using our InteractiveTB. In this fashion, apps which
1853 1853 call sys.excepthook will generate a regular-looking exception from
1854 1854 IPython, and the CrashHandler will only be triggered by real IPython
1855 1855 crashes.
1856 1856
1857 1857 This hook should be used sparingly, only in places which are not likely
1858 1858 to be true IPython errors.
1859 1859 """
1860 1860 self.showtraceback((etype, value, tb), tb_offset=0)
1861 1861
1862 1862 def _get_exc_info(self, exc_tuple=None):
1863 1863 """get exc_info from a given tuple, sys.exc_info() or sys.last_type etc.
1864 1864
1865 1865 Ensures sys.last_type,value,traceback hold the exc_info we found,
1866 1866 from whichever source.
1867 1867
1868 1868 raises ValueError if none of these contain any information
1869 1869 """
1870 1870 if exc_tuple is None:
1871 1871 etype, value, tb = sys.exc_info()
1872 1872 else:
1873 1873 etype, value, tb = exc_tuple
1874 1874
1875 1875 if etype is None:
1876 1876 if hasattr(sys, 'last_type'):
1877 1877 etype, value, tb = sys.last_type, sys.last_value, \
1878 1878 sys.last_traceback
1879 1879
1880 1880 if etype is None:
1881 1881 raise ValueError("No exception to find")
1882 1882
1883 1883 # Now store the exception info in sys.last_type etc.
1884 1884 # WARNING: these variables are somewhat deprecated and not
1885 1885 # necessarily safe to use in a threaded environment, but tools
1886 1886 # like pdb depend on their existence, so let's set them. If we
1887 1887 # find problems in the field, we'll need to revisit their use.
1888 1888 sys.last_type = etype
1889 1889 sys.last_value = value
1890 1890 sys.last_traceback = tb
1891 1891
1892 1892 return etype, value, tb
1893 1893
1894 1894 def show_usage_error(self, exc):
1895 1895 """Show a short message for UsageErrors
1896 1896
1897 1897 These are special exceptions that shouldn't show a traceback.
1898 1898 """
1899 1899 print("UsageError: %s" % exc, file=sys.stderr)
1900 1900
1901 1901 def get_exception_only(self, exc_tuple=None):
1902 1902 """
1903 1903 Return as a string (ending with a newline) the exception that
1904 1904 just occurred, without any traceback.
1905 1905 """
1906 1906 etype, value, tb = self._get_exc_info(exc_tuple)
1907 1907 msg = traceback.format_exception_only(etype, value)
1908 1908 return ''.join(msg)
1909 1909
1910 1910 def showtraceback(self, exc_tuple=None, filename=None, tb_offset=None,
1911 1911 exception_only=False, running_compiled_code=False):
1912 1912 """Display the exception that just occurred.
1913 1913
1914 1914 If nothing is known about the exception, this is the method which
1915 1915 should be used throughout the code for presenting user tracebacks,
1916 1916 rather than directly invoking the InteractiveTB object.
1917 1917
1918 1918 A specific showsyntaxerror() also exists, but this method can take
1919 1919 care of calling it if needed, so unless you are explicitly catching a
1920 1920 SyntaxError exception, don't try to analyze the stack manually and
1921 1921 simply call this method."""
1922 1922
1923 1923 try:
1924 1924 try:
1925 1925 etype, value, tb = self._get_exc_info(exc_tuple)
1926 1926 except ValueError:
1927 1927 print('No traceback available to show.', file=sys.stderr)
1928 1928 return
1929 1929
1930 1930 if issubclass(etype, SyntaxError):
1931 1931 # Though this won't be called by syntax errors in the input
1932 1932 # line, there may be SyntaxError cases with imported code.
1933 1933 self.showsyntaxerror(filename, running_compiled_code)
1934 1934 elif etype is UsageError:
1935 1935 self.show_usage_error(value)
1936 1936 else:
1937 1937 if exception_only:
1938 1938 stb = ['An exception has occurred, use %tb to see '
1939 1939 'the full traceback.\n']
1940 1940 stb.extend(self.InteractiveTB.get_exception_only(etype,
1941 1941 value))
1942 1942 else:
1943 1943 try:
1944 1944 # Exception classes can customise their traceback - we
1945 1945 # use this in IPython.parallel for exceptions occurring
1946 1946 # in the engines. This should return a list of strings.
1947 1947 stb = value._render_traceback_()
1948 1948 except Exception:
1949 1949 stb = self.InteractiveTB.structured_traceback(etype,
1950 1950 value, tb, tb_offset=tb_offset)
1951 1951
1952 1952 self._showtraceback(etype, value, stb)
1953 1953 if self.call_pdb:
1954 1954 # drop into debugger
1955 1955 self.debugger(force=True)
1956 1956 return
1957 1957
1958 1958 # Actually show the traceback
1959 1959 self._showtraceback(etype, value, stb)
1960 1960
1961 1961 except KeyboardInterrupt:
1962 1962 print('\n' + self.get_exception_only(), file=sys.stderr)
1963 1963
1964 1964 def _showtraceback(self, etype, evalue, stb: str):
1965 1965 """Actually show a traceback.
1966 1966
1967 1967 Subclasses may override this method to put the traceback on a different
1968 1968 place, like a side channel.
1969 1969 """
1970 1970 val = self.InteractiveTB.stb2text(stb)
1971 1971 try:
1972 1972 print(val)
1973 1973 except UnicodeEncodeError:
1974 1974 print(val.encode("utf-8", "backslashreplace").decode())
1975 1975
1976 1976 def showsyntaxerror(self, filename=None, running_compiled_code=False):
1977 1977 """Display the syntax error that just occurred.
1978 1978
1979 1979 This doesn't display a stack trace because there isn't one.
1980 1980
1981 1981 If a filename is given, it is stuffed in the exception instead
1982 1982 of what was there before (because Python's parser always uses
1983 1983 "<string>" when reading from a string).
1984 1984
1985 1985 If the syntax error occurred when running a compiled code (i.e. running_compile_code=True),
1986 1986 longer stack trace will be displayed.
1987 1987 """
1988 1988 etype, value, last_traceback = self._get_exc_info()
1989 1989
1990 1990 if filename and issubclass(etype, SyntaxError):
1991 1991 try:
1992 1992 value.filename = filename
1993 1993 except:
1994 1994 # Not the format we expect; leave it alone
1995 1995 pass
1996 1996
1997 1997 # If the error occurred when executing compiled code, we should provide full stacktrace.
1998 1998 elist = traceback.extract_tb(last_traceback) if running_compiled_code else []
1999 1999 stb = self.SyntaxTB.structured_traceback(etype, value, elist)
2000 2000 self._showtraceback(etype, value, stb)
2001 2001
2002 2002 # This is overridden in TerminalInteractiveShell to show a message about
2003 2003 # the %paste magic.
2004 2004 def showindentationerror(self):
2005 2005 """Called by _run_cell when there's an IndentationError in code entered
2006 2006 at the prompt.
2007 2007
2008 2008 This is overridden in TerminalInteractiveShell to show a message about
2009 2009 the %paste magic."""
2010 2010 self.showsyntaxerror()
2011 2011
2012 2012 @skip_doctest
2013 2013 def set_next_input(self, s, replace=False):
2014 2014 """ Sets the 'default' input string for the next command line.
2015 2015
2016 2016 Example::
2017 2017
2018 2018 In [1]: _ip.set_next_input("Hello Word")
2019 2019 In [2]: Hello Word_ # cursor is here
2020 2020 """
2021 2021 self.rl_next_input = s
2022 2022
2023 2023 def _indent_current_str(self):
2024 2024 """return the current level of indentation as a string"""
2025 2025 return self.input_splitter.get_indent_spaces() * ' '
2026 2026
2027 2027 #-------------------------------------------------------------------------
2028 2028 # Things related to text completion
2029 2029 #-------------------------------------------------------------------------
2030 2030
2031 2031 def init_completer(self):
2032 2032 """Initialize the completion machinery.
2033 2033
2034 2034 This creates completion machinery that can be used by client code,
2035 2035 either interactively in-process (typically triggered by the readline
2036 2036 library), programmatically (such as in test suites) or out-of-process
2037 2037 (typically over the network by remote frontends).
2038 2038 """
2039 2039 from IPython.core.completer import IPCompleter
2040 2040 from IPython.core.completerlib import (module_completer,
2041 2041 magic_run_completer, cd_completer, reset_completer)
2042 2042
2043 2043 self.Completer = IPCompleter(shell=self,
2044 2044 namespace=self.user_ns,
2045 2045 global_namespace=self.user_global_ns,
2046 2046 parent=self,
2047 2047 )
2048 2048 self.configurables.append(self.Completer)
2049 2049
2050 2050 # Add custom completers to the basic ones built into IPCompleter
2051 2051 sdisp = self.strdispatchers.get('complete_command', StrDispatch())
2052 2052 self.strdispatchers['complete_command'] = sdisp
2053 2053 self.Completer.custom_completers = sdisp
2054 2054
2055 2055 self.set_hook('complete_command', module_completer, str_key = 'import')
2056 2056 self.set_hook('complete_command', module_completer, str_key = 'from')
2057 2057 self.set_hook('complete_command', module_completer, str_key = '%aimport')
2058 2058 self.set_hook('complete_command', magic_run_completer, str_key = '%run')
2059 2059 self.set_hook('complete_command', cd_completer, str_key = '%cd')
2060 2060 self.set_hook('complete_command', reset_completer, str_key = '%reset')
2061 2061
2062 2062 @skip_doctest
2063 2063 def complete(self, text, line=None, cursor_pos=None):
2064 2064 """Return the completed text and a list of completions.
2065 2065
2066 2066 Parameters
2067 2067 ----------
2068 2068 text : string
2069 2069 A string of text to be completed on. It can be given as empty and
2070 2070 instead a line/position pair are given. In this case, the
2071 2071 completer itself will split the line like readline does.
2072 2072 line : string, optional
2073 2073 The complete line that text is part of.
2074 2074 cursor_pos : int, optional
2075 2075 The position of the cursor on the input line.
2076 2076
2077 2077 Returns
2078 2078 -------
2079 2079 text : string
2080 2080 The actual text that was completed.
2081 2081 matches : list
2082 2082 A sorted list with all possible completions.
2083 2083
2084 2084 Notes
2085 2085 -----
2086 2086 The optional arguments allow the completion to take more context into
2087 2087 account, and are part of the low-level completion API.
2088 2088
2089 2089 This is a wrapper around the completion mechanism, similar to what
2090 2090 readline does at the command line when the TAB key is hit. By
2091 2091 exposing it as a method, it can be used by other non-readline
2092 2092 environments (such as GUIs) for text completion.
2093 2093
2094 2094 Examples
2095 2095 --------
2096 2096 In [1]: x = 'hello'
2097 2097
2098 2098 In [2]: _ip.complete('x.l')
2099 2099 Out[2]: ('x.l', ['x.ljust', 'x.lower', 'x.lstrip'])
2100 2100 """
2101 2101
2102 2102 # Inject names into __builtin__ so we can complete on the added names.
2103 2103 with self.builtin_trap:
2104 2104 return self.Completer.complete(text, line, cursor_pos)
2105 2105
2106 2106 def set_custom_completer(self, completer, pos=0) -> None:
2107 2107 """Adds a new custom completer function.
2108 2108
2109 2109 The position argument (defaults to 0) is the index in the completers
2110 2110 list where you want the completer to be inserted.
2111 2111
2112 2112 `completer` should have the following signature::
2113 2113
2114 2114 def completion(self: Completer, text: string) -> List[str]:
2115 2115 raise NotImplementedError
2116 2116
2117 2117 It will be bound to the current Completer instance and pass some text
2118 2118 and return a list with current completions to suggest to the user.
2119 2119 """
2120 2120
2121 2121 newcomp = types.MethodType(completer, self.Completer)
2122 2122 self.Completer.custom_matchers.insert(pos,newcomp)
2123 2123
2124 2124 def set_completer_frame(self, frame=None):
2125 2125 """Set the frame of the completer."""
2126 2126 if frame:
2127 2127 self.Completer.namespace = frame.f_locals
2128 2128 self.Completer.global_namespace = frame.f_globals
2129 2129 else:
2130 2130 self.Completer.namespace = self.user_ns
2131 2131 self.Completer.global_namespace = self.user_global_ns
2132 2132
2133 2133 #-------------------------------------------------------------------------
2134 2134 # Things related to magics
2135 2135 #-------------------------------------------------------------------------
2136 2136
2137 2137 def init_magics(self):
2138 2138 from IPython.core import magics as m
2139 2139 self.magics_manager = magic.MagicsManager(shell=self,
2140 2140 parent=self,
2141 2141 user_magics=m.UserMagics(self))
2142 2142 self.configurables.append(self.magics_manager)
2143 2143
2144 2144 # Expose as public API from the magics manager
2145 2145 self.register_magics = self.magics_manager.register
2146 2146
2147 2147 self.register_magics(m.AutoMagics, m.BasicMagics, m.CodeMagics,
2148 2148 m.ConfigMagics, m.DisplayMagics, m.ExecutionMagics,
2149 2149 m.ExtensionMagics, m.HistoryMagics, m.LoggingMagics,
2150 2150 m.NamespaceMagics, m.OSMagics, m.PackagingMagics,
2151 2151 m.PylabMagics, m.ScriptMagics,
2152 2152 )
2153 2153 self.register_magics(m.AsyncMagics)
2154 2154
2155 2155 # Register Magic Aliases
2156 2156 mman = self.magics_manager
2157 2157 # FIXME: magic aliases should be defined by the Magics classes
2158 2158 # or in MagicsManager, not here
2159 2159 mman.register_alias('ed', 'edit')
2160 2160 mman.register_alias('hist', 'history')
2161 2161 mman.register_alias('rep', 'recall')
2162 2162 mman.register_alias('SVG', 'svg', 'cell')
2163 2163 mman.register_alias('HTML', 'html', 'cell')
2164 2164 mman.register_alias('file', 'writefile', 'cell')
2165 2165
2166 2166 # FIXME: Move the color initialization to the DisplayHook, which
2167 2167 # should be split into a prompt manager and displayhook. We probably
2168 2168 # even need a centralize colors management object.
2169 2169 self.run_line_magic('colors', self.colors)
2170 2170
2171 2171 # Defined here so that it's included in the documentation
2172 2172 @functools.wraps(magic.MagicsManager.register_function)
2173 2173 def register_magic_function(self, func, magic_kind='line', magic_name=None):
2174 2174 self.magics_manager.register_function(
2175 2175 func, magic_kind=magic_kind, magic_name=magic_name
2176 2176 )
2177 2177
2178 2178 def _find_with_lazy_load(self, /, type_, magic_name: str):
2179 2179 """
2180 2180 Try to find a magic potentially lazy-loading it.
2181 2181
2182 2182 Parameters
2183 2183 ----------
2184 2184
2185 2185 type_: "line"|"cell"
2186 2186 the type of magics we are trying to find/lazy load.
2187 2187 magic_name: str
2188 2188 The name of the magic we are trying to find/lazy load
2189 2189
2190 2190
2191 2191 Note that this may have any side effects
2192 2192 """
2193 2193 finder = {"line": self.find_line_magic, "cell": self.find_cell_magic}[type_]
2194 2194 fn = finder(magic_name)
2195 2195 if fn is not None:
2196 2196 return fn
2197 2197 lazy = self.magics_manager.lazy_magics.get(magic_name)
2198 2198 if lazy is None:
2199 2199 return None
2200 2200
2201 2201 self.run_line_magic("load_ext", lazy)
2202 2202 res = finder(magic_name)
2203 2203 return res
2204 2204
2205 2205 def run_line_magic(self, magic_name: str, line, _stack_depth=1):
2206 2206 """Execute the given line magic.
2207 2207
2208 2208 Parameters
2209 2209 ----------
2210 2210 magic_name : str
2211 2211 Name of the desired magic function, without '%' prefix.
2212 2212 line : str
2213 2213 The rest of the input line as a single string.
2214 2214 _stack_depth : int
2215 2215 If run_line_magic() is called from magic() then _stack_depth=2.
2216 2216 This is added to ensure backward compatibility for use of 'get_ipython().magic()'
2217 2217 """
2218 2218 fn = self._find_with_lazy_load("line", magic_name)
2219 2219 if fn is None:
2220 2220 lazy = self.magics_manager.lazy_magics.get(magic_name)
2221 2221 if lazy:
2222 2222 self.run_line_magic("load_ext", lazy)
2223 2223 fn = self.find_line_magic(magic_name)
2224 2224 if fn is None:
2225 2225 cm = self.find_cell_magic(magic_name)
2226 2226 etpl = "Line magic function `%%%s` not found%s."
2227 2227 extra = '' if cm is None else (' (But cell magic `%%%%%s` exists, '
2228 2228 'did you mean that instead?)' % magic_name )
2229 2229 raise UsageError(etpl % (magic_name, extra))
2230 2230 else:
2231 2231 # Note: this is the distance in the stack to the user's frame.
2232 2232 # This will need to be updated if the internal calling logic gets
2233 2233 # refactored, or else we'll be expanding the wrong variables.
2234 2234
2235 2235 # Determine stack_depth depending on where run_line_magic() has been called
2236 2236 stack_depth = _stack_depth
2237 2237 if getattr(fn, magic.MAGIC_NO_VAR_EXPAND_ATTR, False):
2238 2238 # magic has opted out of var_expand
2239 2239 magic_arg_s = line
2240 2240 else:
2241 2241 magic_arg_s = self.var_expand(line, stack_depth)
2242 2242 # Put magic args in a list so we can call with f(*a) syntax
2243 2243 args = [magic_arg_s]
2244 2244 kwargs = {}
2245 2245 # Grab local namespace if we need it:
2246 2246 if getattr(fn, "needs_local_scope", False):
2247 2247 kwargs['local_ns'] = self.get_local_scope(stack_depth)
2248 2248 with self.builtin_trap:
2249 2249 result = fn(*args, **kwargs)
2250 2250 return result
2251 2251
2252 2252 def get_local_scope(self, stack_depth):
2253 2253 """Get local scope at given stack depth.
2254 2254
2255 2255 Parameters
2256 2256 ----------
2257 2257 stack_depth : int
2258 2258 Depth relative to calling frame
2259 2259 """
2260 2260 return sys._getframe(stack_depth + 1).f_locals
2261 2261
2262 2262 def run_cell_magic(self, magic_name, line, cell):
2263 2263 """Execute the given cell magic.
2264 2264
2265 2265 Parameters
2266 2266 ----------
2267 2267 magic_name : str
2268 2268 Name of the desired magic function, without '%' prefix.
2269 2269 line : str
2270 2270 The rest of the first input line as a single string.
2271 2271 cell : str
2272 2272 The body of the cell as a (possibly multiline) string.
2273 2273 """
2274 2274 fn = self._find_with_lazy_load("cell", magic_name)
2275 2275 if fn is None:
2276 2276 lm = self.find_line_magic(magic_name)
2277 2277 etpl = "Cell magic `%%{0}` not found{1}."
2278 2278 extra = '' if lm is None else (' (But line magic `%{0}` exists, '
2279 2279 'did you mean that instead?)'.format(magic_name))
2280 2280 raise UsageError(etpl.format(magic_name, extra))
2281 2281 elif cell == '':
2282 2282 message = '%%{0} is a cell magic, but the cell body is empty.'.format(magic_name)
2283 2283 if self.find_line_magic(magic_name) is not None:
2284 2284 message += ' Did you mean the line magic %{0} (single %)?'.format(magic_name)
2285 2285 raise UsageError(message)
2286 2286 else:
2287 2287 # Note: this is the distance in the stack to the user's frame.
2288 2288 # This will need to be updated if the internal calling logic gets
2289 2289 # refactored, or else we'll be expanding the wrong variables.
2290 2290 stack_depth = 2
2291 2291 if getattr(fn, magic.MAGIC_NO_VAR_EXPAND_ATTR, False):
2292 2292 # magic has opted out of var_expand
2293 2293 magic_arg_s = line
2294 2294 else:
2295 2295 magic_arg_s = self.var_expand(line, stack_depth)
2296 2296 kwargs = {}
2297 2297 if getattr(fn, "needs_local_scope", False):
2298 2298 kwargs['local_ns'] = self.user_ns
2299 2299
2300 2300 with self.builtin_trap:
2301 2301 args = (magic_arg_s, cell)
2302 2302 result = fn(*args, **kwargs)
2303 2303 return result
2304 2304
2305 2305 def find_line_magic(self, magic_name):
2306 2306 """Find and return a line magic by name.
2307 2307
2308 2308 Returns None if the magic isn't found."""
2309 2309 return self.magics_manager.magics['line'].get(magic_name)
2310 2310
2311 2311 def find_cell_magic(self, magic_name):
2312 2312 """Find and return a cell magic by name.
2313 2313
2314 2314 Returns None if the magic isn't found."""
2315 2315 return self.magics_manager.magics['cell'].get(magic_name)
2316 2316
2317 2317 def find_magic(self, magic_name, magic_kind='line'):
2318 2318 """Find and return a magic of the given type by name.
2319 2319
2320 2320 Returns None if the magic isn't found."""
2321 2321 return self.magics_manager.magics[magic_kind].get(magic_name)
2322 2322
2323 2323 def magic(self, arg_s):
2324 2324 """
2325 2325 DEPRECATED
2326 2326
2327 2327 Deprecated since IPython 0.13 (warning added in
2328 2328 8.1), use run_line_magic(magic_name, parameter_s).
2329 2329
2330 2330 Call a magic function by name.
2331 2331
2332 2332 Input: a string containing the name of the magic function to call and
2333 2333 any additional arguments to be passed to the magic.
2334 2334
2335 2335 magic('name -opt foo bar') is equivalent to typing at the ipython
2336 2336 prompt:
2337 2337
2338 2338 In[1]: %name -opt foo bar
2339 2339
2340 2340 To call a magic without arguments, simply use magic('name').
2341 2341
2342 2342 This provides a proper Python function to call IPython's magics in any
2343 2343 valid Python code you can type at the interpreter, including loops and
2344 2344 compound statements.
2345 2345 """
2346 2346 warnings.warn(
2347 2347 "`magic(...)` is deprecated since IPython 0.13 (warning added in "
2348 2348 "8.1), use run_line_magic(magic_name, parameter_s).",
2349 2349 DeprecationWarning,
2350 2350 stacklevel=2,
2351 2351 )
2352 2352 # TODO: should we issue a loud deprecation warning here?
2353 2353 magic_name, _, magic_arg_s = arg_s.partition(' ')
2354 2354 magic_name = magic_name.lstrip(prefilter.ESC_MAGIC)
2355 2355 return self.run_line_magic(magic_name, magic_arg_s, _stack_depth=2)
2356 2356
2357 2357 #-------------------------------------------------------------------------
2358 2358 # Things related to macros
2359 2359 #-------------------------------------------------------------------------
2360 2360
2361 2361 def define_macro(self, name, themacro):
2362 2362 """Define a new macro
2363 2363
2364 2364 Parameters
2365 2365 ----------
2366 2366 name : str
2367 2367 The name of the macro.
2368 2368 themacro : str or Macro
2369 2369 The action to do upon invoking the macro. If a string, a new
2370 2370 Macro object is created by passing the string to it.
2371 2371 """
2372 2372
2373 2373 from IPython.core import macro
2374 2374
2375 2375 if isinstance(themacro, str):
2376 2376 themacro = macro.Macro(themacro)
2377 2377 if not isinstance(themacro, macro.Macro):
2378 2378 raise ValueError('A macro must be a string or a Macro instance.')
2379 2379 self.user_ns[name] = themacro
2380 2380
2381 2381 #-------------------------------------------------------------------------
2382 2382 # Things related to the running of system commands
2383 2383 #-------------------------------------------------------------------------
2384 2384
2385 2385 def system_piped(self, cmd):
2386 2386 """Call the given cmd in a subprocess, piping stdout/err
2387 2387
2388 2388 Parameters
2389 2389 ----------
2390 2390 cmd : str
2391 2391 Command to execute (can not end in '&', as background processes are
2392 2392 not supported. Should not be a command that expects input
2393 2393 other than simple text.
2394 2394 """
2395 2395 if cmd.rstrip().endswith('&'):
2396 2396 # this is *far* from a rigorous test
2397 2397 # We do not support backgrounding processes because we either use
2398 2398 # pexpect or pipes to read from. Users can always just call
2399 2399 # os.system() or use ip.system=ip.system_raw
2400 2400 # if they really want a background process.
2401 2401 raise OSError("Background processes not supported.")
2402 2402
2403 2403 # we explicitly do NOT return the subprocess status code, because
2404 2404 # a non-None value would trigger :func:`sys.displayhook` calls.
2405 2405 # Instead, we store the exit_code in user_ns.
2406 2406 self.user_ns['_exit_code'] = system(self.var_expand(cmd, depth=1))
2407 2407
2408 2408 def system_raw(self, cmd):
2409 2409 """Call the given cmd in a subprocess using os.system on Windows or
2410 2410 subprocess.call using the system shell on other platforms.
2411 2411
2412 2412 Parameters
2413 2413 ----------
2414 2414 cmd : str
2415 2415 Command to execute.
2416 2416 """
2417 2417 cmd = self.var_expand(cmd, depth=1)
2418 2418 # warn if there is an IPython magic alternative.
2419 2419 main_cmd = cmd.split()[0]
2420 has_magic_alternatives = ("pip", "conda", "cd", "ls")
2420 has_magic_alternatives = ("pip", "conda", "cd")
2421 2421
2422 # had to check if the command was an alias expanded because of `ls`
2423 is_alias_expanded = self.alias_manager.is_alias(main_cmd) and (
2424 self.alias_manager.retrieve_alias(main_cmd).strip() == cmd.strip()
2425 )
2426
2427 if main_cmd in has_magic_alternatives and not is_alias_expanded:
2422 if main_cmd in has_magic_alternatives:
2428 2423 warnings.warn(
2429 2424 (
2430 2425 "You executed the system command !{0} which may not work "
2431 2426 "as expected. Try the IPython magic %{0} instead."
2432 2427 ).format(main_cmd)
2433 2428 )
2434 2429
2435 2430 # protect os.system from UNC paths on Windows, which it can't handle:
2436 2431 if sys.platform == 'win32':
2437 2432 from IPython.utils._process_win32 import AvoidUNCPath
2438 2433 with AvoidUNCPath() as path:
2439 2434 if path is not None:
2440 2435 cmd = '"pushd %s &&"%s' % (path, cmd)
2441 2436 try:
2442 2437 ec = os.system(cmd)
2443 2438 except KeyboardInterrupt:
2444 2439 print('\n' + self.get_exception_only(), file=sys.stderr)
2445 2440 ec = -2
2446 2441 else:
2447 2442 # For posix the result of the subprocess.call() below is an exit
2448 2443 # code, which by convention is zero for success, positive for
2449 2444 # program failure. Exit codes above 128 are reserved for signals,
2450 2445 # and the formula for converting a signal to an exit code is usually
2451 2446 # signal_number+128. To more easily differentiate between exit
2452 2447 # codes and signals, ipython uses negative numbers. For instance
2453 2448 # since control-c is signal 2 but exit code 130, ipython's
2454 2449 # _exit_code variable will read -2. Note that some shells like
2455 2450 # csh and fish don't follow sh/bash conventions for exit codes.
2456 2451 executable = os.environ.get('SHELL', None)
2457 2452 try:
2458 2453 # Use env shell instead of default /bin/sh
2459 2454 ec = subprocess.call(cmd, shell=True, executable=executable)
2460 2455 except KeyboardInterrupt:
2461 2456 # intercept control-C; a long traceback is not useful here
2462 2457 print('\n' + self.get_exception_only(), file=sys.stderr)
2463 2458 ec = 130
2464 2459 if ec > 128:
2465 2460 ec = -(ec - 128)
2466 2461
2467 2462 # We explicitly do NOT return the subprocess status code, because
2468 2463 # a non-None value would trigger :func:`sys.displayhook` calls.
2469 2464 # Instead, we store the exit_code in user_ns. Note the semantics
2470 2465 # of _exit_code: for control-c, _exit_code == -signal.SIGNIT,
2471 2466 # but raising SystemExit(_exit_code) will give status 254!
2472 2467 self.user_ns['_exit_code'] = ec
2473 2468
2474 2469 # use piped system by default, because it is better behaved
2475 2470 system = system_piped
2476 2471
2477 2472 def getoutput(self, cmd, split=True, depth=0):
2478 2473 """Get output (possibly including stderr) from a subprocess.
2479 2474
2480 2475 Parameters
2481 2476 ----------
2482 2477 cmd : str
2483 2478 Command to execute (can not end in '&', as background processes are
2484 2479 not supported.
2485 2480 split : bool, optional
2486 2481 If True, split the output into an IPython SList. Otherwise, an
2487 2482 IPython LSString is returned. These are objects similar to normal
2488 2483 lists and strings, with a few convenience attributes for easier
2489 2484 manipulation of line-based output. You can use '?' on them for
2490 2485 details.
2491 2486 depth : int, optional
2492 2487 How many frames above the caller are the local variables which should
2493 2488 be expanded in the command string? The default (0) assumes that the
2494 2489 expansion variables are in the stack frame calling this function.
2495 2490 """
2496 2491 if cmd.rstrip().endswith('&'):
2497 2492 # this is *far* from a rigorous test
2498 2493 raise OSError("Background processes not supported.")
2499 2494 out = getoutput(self.var_expand(cmd, depth=depth+1))
2500 2495 if split:
2501 2496 out = SList(out.splitlines())
2502 2497 else:
2503 2498 out = LSString(out)
2504 2499 return out
2505 2500
2506 2501 #-------------------------------------------------------------------------
2507 2502 # Things related to aliases
2508 2503 #-------------------------------------------------------------------------
2509 2504
2510 2505 def init_alias(self):
2511 2506 self.alias_manager = AliasManager(shell=self, parent=self)
2512 2507 self.configurables.append(self.alias_manager)
2513 2508
2514 2509 #-------------------------------------------------------------------------
2515 2510 # Things related to extensions
2516 2511 #-------------------------------------------------------------------------
2517 2512
2518 2513 def init_extension_manager(self):
2519 2514 self.extension_manager = ExtensionManager(shell=self, parent=self)
2520 2515 self.configurables.append(self.extension_manager)
2521 2516
2522 2517 #-------------------------------------------------------------------------
2523 2518 # Things related to payloads
2524 2519 #-------------------------------------------------------------------------
2525 2520
2526 2521 def init_payload(self):
2527 2522 self.payload_manager = PayloadManager(parent=self)
2528 2523 self.configurables.append(self.payload_manager)
2529 2524
2530 2525 #-------------------------------------------------------------------------
2531 2526 # Things related to the prefilter
2532 2527 #-------------------------------------------------------------------------
2533 2528
2534 2529 def init_prefilter(self):
2535 2530 self.prefilter_manager = PrefilterManager(shell=self, parent=self)
2536 2531 self.configurables.append(self.prefilter_manager)
2537 2532 # Ultimately this will be refactored in the new interpreter code, but
2538 2533 # for now, we should expose the main prefilter method (there's legacy
2539 2534 # code out there that may rely on this).
2540 2535 self.prefilter = self.prefilter_manager.prefilter_lines
2541 2536
2542 2537 def auto_rewrite_input(self, cmd):
2543 2538 """Print to the screen the rewritten form of the user's command.
2544 2539
2545 2540 This shows visual feedback by rewriting input lines that cause
2546 2541 automatic calling to kick in, like::
2547 2542
2548 2543 /f x
2549 2544
2550 2545 into::
2551 2546
2552 2547 ------> f(x)
2553 2548
2554 2549 after the user's input prompt. This helps the user understand that the
2555 2550 input line was transformed automatically by IPython.
2556 2551 """
2557 2552 if not self.show_rewritten_input:
2558 2553 return
2559 2554
2560 2555 # This is overridden in TerminalInteractiveShell to use fancy prompts
2561 2556 print("------> " + cmd)
2562 2557
2563 2558 #-------------------------------------------------------------------------
2564 2559 # Things related to extracting values/expressions from kernel and user_ns
2565 2560 #-------------------------------------------------------------------------
2566 2561
2567 2562 def _user_obj_error(self):
2568 2563 """return simple exception dict
2569 2564
2570 2565 for use in user_expressions
2571 2566 """
2572 2567
2573 2568 etype, evalue, tb = self._get_exc_info()
2574 2569 stb = self.InteractiveTB.get_exception_only(etype, evalue)
2575 2570
2576 2571 exc_info = {
2577 2572 "status": "error",
2578 2573 "traceback": stb,
2579 2574 "ename": etype.__name__,
2580 2575 "evalue": py3compat.safe_unicode(evalue),
2581 2576 }
2582 2577
2583 2578 return exc_info
2584 2579
2585 2580 def _format_user_obj(self, obj):
2586 2581 """format a user object to display dict
2587 2582
2588 2583 for use in user_expressions
2589 2584 """
2590 2585
2591 2586 data, md = self.display_formatter.format(obj)
2592 2587 value = {
2593 2588 'status' : 'ok',
2594 2589 'data' : data,
2595 2590 'metadata' : md,
2596 2591 }
2597 2592 return value
2598 2593
2599 2594 def user_expressions(self, expressions):
2600 2595 """Evaluate a dict of expressions in the user's namespace.
2601 2596
2602 2597 Parameters
2603 2598 ----------
2604 2599 expressions : dict
2605 2600 A dict with string keys and string values. The expression values
2606 2601 should be valid Python expressions, each of which will be evaluated
2607 2602 in the user namespace.
2608 2603
2609 2604 Returns
2610 2605 -------
2611 2606 A dict, keyed like the input expressions dict, with the rich mime-typed
2612 2607 display_data of each value.
2613 2608 """
2614 2609 out = {}
2615 2610 user_ns = self.user_ns
2616 2611 global_ns = self.user_global_ns
2617 2612
2618 2613 for key, expr in expressions.items():
2619 2614 try:
2620 2615 value = self._format_user_obj(eval(expr, global_ns, user_ns))
2621 2616 except:
2622 2617 value = self._user_obj_error()
2623 2618 out[key] = value
2624 2619 return out
2625 2620
2626 2621 #-------------------------------------------------------------------------
2627 2622 # Things related to the running of code
2628 2623 #-------------------------------------------------------------------------
2629 2624
2630 2625 def ex(self, cmd):
2631 2626 """Execute a normal python statement in user namespace."""
2632 2627 with self.builtin_trap:
2633 2628 exec(cmd, self.user_global_ns, self.user_ns)
2634 2629
2635 2630 def ev(self, expr):
2636 2631 """Evaluate python expression expr in user namespace.
2637 2632
2638 2633 Returns the result of evaluation
2639 2634 """
2640 2635 with self.builtin_trap:
2641 2636 return eval(expr, self.user_global_ns, self.user_ns)
2642 2637
2643 2638 def safe_execfile(self, fname, *where, exit_ignore=False, raise_exceptions=False, shell_futures=False):
2644 2639 """A safe version of the builtin execfile().
2645 2640
2646 2641 This version will never throw an exception, but instead print
2647 2642 helpful error messages to the screen. This only works on pure
2648 2643 Python files with the .py extension.
2649 2644
2650 2645 Parameters
2651 2646 ----------
2652 2647 fname : string
2653 2648 The name of the file to be executed.
2654 2649 *where : tuple
2655 2650 One or two namespaces, passed to execfile() as (globals,locals).
2656 2651 If only one is given, it is passed as both.
2657 2652 exit_ignore : bool (False)
2658 2653 If True, then silence SystemExit for non-zero status (it is always
2659 2654 silenced for zero status, as it is so common).
2660 2655 raise_exceptions : bool (False)
2661 2656 If True raise exceptions everywhere. Meant for testing.
2662 2657 shell_futures : bool (False)
2663 2658 If True, the code will share future statements with the interactive
2664 2659 shell. It will both be affected by previous __future__ imports, and
2665 2660 any __future__ imports in the code will affect the shell. If False,
2666 2661 __future__ imports are not shared in either direction.
2667 2662
2668 2663 """
2669 2664 fname = Path(fname).expanduser().resolve()
2670 2665
2671 2666 # Make sure we can open the file
2672 2667 try:
2673 2668 with fname.open("rb"):
2674 2669 pass
2675 2670 except:
2676 2671 warn('Could not open file <%s> for safe execution.' % fname)
2677 2672 return
2678 2673
2679 2674 # Find things also in current directory. This is needed to mimic the
2680 2675 # behavior of running a script from the system command line, where
2681 2676 # Python inserts the script's directory into sys.path
2682 2677 dname = str(fname.parent)
2683 2678
2684 2679 with prepended_to_syspath(dname), self.builtin_trap:
2685 2680 try:
2686 2681 glob, loc = (where + (None, ))[:2]
2687 2682 py3compat.execfile(
2688 2683 fname, glob, loc,
2689 2684 self.compile if shell_futures else None)
2690 2685 except SystemExit as status:
2691 2686 # If the call was made with 0 or None exit status (sys.exit(0)
2692 2687 # or sys.exit() ), don't bother showing a traceback, as both of
2693 2688 # these are considered normal by the OS:
2694 2689 # > python -c'import sys;sys.exit(0)'; echo $?
2695 2690 # 0
2696 2691 # > python -c'import sys;sys.exit()'; echo $?
2697 2692 # 0
2698 2693 # For other exit status, we show the exception unless
2699 2694 # explicitly silenced, but only in short form.
2700 2695 if status.code:
2701 2696 if raise_exceptions:
2702 2697 raise
2703 2698 if not exit_ignore:
2704 2699 self.showtraceback(exception_only=True)
2705 2700 except:
2706 2701 if raise_exceptions:
2707 2702 raise
2708 2703 # tb offset is 2 because we wrap execfile
2709 2704 self.showtraceback(tb_offset=2)
2710 2705
2711 2706 def safe_execfile_ipy(self, fname, shell_futures=False, raise_exceptions=False):
2712 2707 """Like safe_execfile, but for .ipy or .ipynb files with IPython syntax.
2713 2708
2714 2709 Parameters
2715 2710 ----------
2716 2711 fname : str
2717 2712 The name of the file to execute. The filename must have a
2718 2713 .ipy or .ipynb extension.
2719 2714 shell_futures : bool (False)
2720 2715 If True, the code will share future statements with the interactive
2721 2716 shell. It will both be affected by previous __future__ imports, and
2722 2717 any __future__ imports in the code will affect the shell. If False,
2723 2718 __future__ imports are not shared in either direction.
2724 2719 raise_exceptions : bool (False)
2725 2720 If True raise exceptions everywhere. Meant for testing.
2726 2721 """
2727 2722 fname = Path(fname).expanduser().resolve()
2728 2723
2729 2724 # Make sure we can open the file
2730 2725 try:
2731 2726 with fname.open("rb"):
2732 2727 pass
2733 2728 except:
2734 2729 warn('Could not open file <%s> for safe execution.' % fname)
2735 2730 return
2736 2731
2737 2732 # Find things also in current directory. This is needed to mimic the
2738 2733 # behavior of running a script from the system command line, where
2739 2734 # Python inserts the script's directory into sys.path
2740 2735 dname = str(fname.parent)
2741 2736
2742 2737 def get_cells():
2743 2738 """generator for sequence of code blocks to run"""
2744 2739 if fname.suffix == ".ipynb":
2745 2740 from nbformat import read
2746 2741 nb = read(fname, as_version=4)
2747 2742 if not nb.cells:
2748 2743 return
2749 2744 for cell in nb.cells:
2750 2745 if cell.cell_type == 'code':
2751 2746 yield cell.source
2752 2747 else:
2753 2748 yield fname.read_text(encoding="utf-8")
2754 2749
2755 2750 with prepended_to_syspath(dname):
2756 2751 try:
2757 2752 for cell in get_cells():
2758 2753 result = self.run_cell(cell, silent=True, shell_futures=shell_futures)
2759 2754 if raise_exceptions:
2760 2755 result.raise_error()
2761 2756 elif not result.success:
2762 2757 break
2763 2758 except:
2764 2759 if raise_exceptions:
2765 2760 raise
2766 2761 self.showtraceback()
2767 2762 warn('Unknown failure executing file: <%s>' % fname)
2768 2763
2769 2764 def safe_run_module(self, mod_name, where):
2770 2765 """A safe version of runpy.run_module().
2771 2766
2772 2767 This version will never throw an exception, but instead print
2773 2768 helpful error messages to the screen.
2774 2769
2775 2770 `SystemExit` exceptions with status code 0 or None are ignored.
2776 2771
2777 2772 Parameters
2778 2773 ----------
2779 2774 mod_name : string
2780 2775 The name of the module to be executed.
2781 2776 where : dict
2782 2777 The globals namespace.
2783 2778 """
2784 2779 try:
2785 2780 try:
2786 2781 where.update(
2787 2782 runpy.run_module(str(mod_name), run_name="__main__",
2788 2783 alter_sys=True)
2789 2784 )
2790 2785 except SystemExit as status:
2791 2786 if status.code:
2792 2787 raise
2793 2788 except:
2794 2789 self.showtraceback()
2795 2790 warn('Unknown failure executing module: <%s>' % mod_name)
2796 2791
2797 2792 def run_cell(self, raw_cell, store_history=False, silent=False, shell_futures=True):
2798 2793 """Run a complete IPython cell.
2799 2794
2800 2795 Parameters
2801 2796 ----------
2802 2797 raw_cell : str
2803 2798 The code (including IPython code such as %magic functions) to run.
2804 2799 store_history : bool
2805 2800 If True, the raw and translated cell will be stored in IPython's
2806 2801 history. For user code calling back into IPython's machinery, this
2807 2802 should be set to False.
2808 2803 silent : bool
2809 2804 If True, avoid side-effects, such as implicit displayhooks and
2810 2805 and logging. silent=True forces store_history=False.
2811 2806 shell_futures : bool
2812 2807 If True, the code will share future statements with the interactive
2813 2808 shell. It will both be affected by previous __future__ imports, and
2814 2809 any __future__ imports in the code will affect the shell. If False,
2815 2810 __future__ imports are not shared in either direction.
2816 2811
2817 2812 Returns
2818 2813 -------
2819 2814 result : :class:`ExecutionResult`
2820 2815 """
2821 2816 result = None
2822 2817 try:
2823 2818 result = self._run_cell(
2824 2819 raw_cell, store_history, silent, shell_futures)
2825 2820 finally:
2826 2821 self.events.trigger('post_execute')
2827 2822 if not silent:
2828 2823 self.events.trigger('post_run_cell', result)
2829 2824 return result
2830 2825
2831 2826 def _run_cell(self, raw_cell:str, store_history:bool, silent:bool, shell_futures:bool) -> ExecutionResult:
2832 2827 """Internal method to run a complete IPython cell."""
2833 2828
2834 2829 # we need to avoid calling self.transform_cell multiple time on the same thing
2835 2830 # so we need to store some results:
2836 2831 preprocessing_exc_tuple = None
2837 2832 try:
2838 2833 transformed_cell = self.transform_cell(raw_cell)
2839 2834 except Exception:
2840 2835 transformed_cell = raw_cell
2841 2836 preprocessing_exc_tuple = sys.exc_info()
2842 2837
2843 2838 assert transformed_cell is not None
2844 2839 coro = self.run_cell_async(
2845 2840 raw_cell,
2846 2841 store_history=store_history,
2847 2842 silent=silent,
2848 2843 shell_futures=shell_futures,
2849 2844 transformed_cell=transformed_cell,
2850 2845 preprocessing_exc_tuple=preprocessing_exc_tuple,
2851 2846 )
2852 2847
2853 2848 # run_cell_async is async, but may not actually need an eventloop.
2854 2849 # when this is the case, we want to run it using the pseudo_sync_runner
2855 2850 # so that code can invoke eventloops (for example via the %run , and
2856 2851 # `%paste` magic.
2857 2852 if self.trio_runner:
2858 2853 runner = self.trio_runner
2859 2854 elif self.should_run_async(
2860 2855 raw_cell,
2861 2856 transformed_cell=transformed_cell,
2862 2857 preprocessing_exc_tuple=preprocessing_exc_tuple,
2863 2858 ):
2864 2859 runner = self.loop_runner
2865 2860 else:
2866 2861 runner = _pseudo_sync_runner
2867 2862
2868 2863 try:
2869 2864 return runner(coro)
2870 2865 except BaseException as e:
2871 2866 info = ExecutionInfo(raw_cell, store_history, silent, shell_futures)
2872 2867 result = ExecutionResult(info)
2873 2868 result.error_in_exec = e
2874 2869 self.showtraceback(running_compiled_code=True)
2875 2870 return result
2876 2871
2877 2872 def should_run_async(
2878 2873 self, raw_cell: str, *, transformed_cell=None, preprocessing_exc_tuple=None
2879 2874 ) -> bool:
2880 2875 """Return whether a cell should be run asynchronously via a coroutine runner
2881 2876
2882 2877 Parameters
2883 2878 ----------
2884 2879 raw_cell : str
2885 2880 The code to be executed
2886 2881
2887 2882 Returns
2888 2883 -------
2889 2884 result: bool
2890 2885 Whether the code needs to be run with a coroutine runner or not
2891 2886 .. versionadded:: 7.0
2892 2887 """
2893 2888 if not self.autoawait:
2894 2889 return False
2895 2890 if preprocessing_exc_tuple is not None:
2896 2891 return False
2897 2892 assert preprocessing_exc_tuple is None
2898 2893 if transformed_cell is None:
2899 2894 warnings.warn(
2900 2895 "`should_run_async` will not call `transform_cell`"
2901 2896 " automatically in the future. Please pass the result to"
2902 2897 " `transformed_cell` argument and any exception that happen"
2903 2898 " during the"
2904 2899 "transform in `preprocessing_exc_tuple` in"
2905 2900 " IPython 7.17 and above.",
2906 2901 DeprecationWarning,
2907 2902 stacklevel=2,
2908 2903 )
2909 2904 try:
2910 2905 cell = self.transform_cell(raw_cell)
2911 2906 except Exception:
2912 2907 # any exception during transform will be raised
2913 2908 # prior to execution
2914 2909 return False
2915 2910 else:
2916 2911 cell = transformed_cell
2917 2912 return _should_be_async(cell)
2918 2913
2919 2914 async def run_cell_async(
2920 2915 self,
2921 2916 raw_cell: str,
2922 2917 store_history=False,
2923 2918 silent=False,
2924 2919 shell_futures=True,
2925 2920 *,
2926 2921 transformed_cell: Optional[str] = None,
2927 2922 preprocessing_exc_tuple: Optional[Any] = None
2928 2923 ) -> ExecutionResult:
2929 2924 """Run a complete IPython cell asynchronously.
2930 2925
2931 2926 Parameters
2932 2927 ----------
2933 2928 raw_cell : str
2934 2929 The code (including IPython code such as %magic functions) to run.
2935 2930 store_history : bool
2936 2931 If True, the raw and translated cell will be stored in IPython's
2937 2932 history. For user code calling back into IPython's machinery, this
2938 2933 should be set to False.
2939 2934 silent : bool
2940 2935 If True, avoid side-effects, such as implicit displayhooks and
2941 2936 and logging. silent=True forces store_history=False.
2942 2937 shell_futures : bool
2943 2938 If True, the code will share future statements with the interactive
2944 2939 shell. It will both be affected by previous __future__ imports, and
2945 2940 any __future__ imports in the code will affect the shell. If False,
2946 2941 __future__ imports are not shared in either direction.
2947 2942 transformed_cell: str
2948 2943 cell that was passed through transformers
2949 2944 preprocessing_exc_tuple:
2950 2945 trace if the transformation failed.
2951 2946
2952 2947 Returns
2953 2948 -------
2954 2949 result : :class:`ExecutionResult`
2955 2950
2956 2951 .. versionadded:: 7.0
2957 2952 """
2958 2953 info = ExecutionInfo(
2959 2954 raw_cell, store_history, silent, shell_futures)
2960 2955 result = ExecutionResult(info)
2961 2956
2962 2957 if (not raw_cell) or raw_cell.isspace():
2963 2958 self.last_execution_succeeded = True
2964 2959 self.last_execution_result = result
2965 2960 return result
2966 2961
2967 2962 if silent:
2968 2963 store_history = False
2969 2964
2970 2965 if store_history:
2971 2966 result.execution_count = self.execution_count
2972 2967
2973 2968 def error_before_exec(value):
2974 2969 if store_history:
2975 2970 self.execution_count += 1
2976 2971 result.error_before_exec = value
2977 2972 self.last_execution_succeeded = False
2978 2973 self.last_execution_result = result
2979 2974 return result
2980 2975
2981 2976 self.events.trigger('pre_execute')
2982 2977 if not silent:
2983 2978 self.events.trigger('pre_run_cell', info)
2984 2979
2985 2980 if transformed_cell is None:
2986 2981 warnings.warn(
2987 2982 "`run_cell_async` will not call `transform_cell`"
2988 2983 " automatically in the future. Please pass the result to"
2989 2984 " `transformed_cell` argument and any exception that happen"
2990 2985 " during the"
2991 2986 "transform in `preprocessing_exc_tuple` in"
2992 2987 " IPython 7.17 and above.",
2993 2988 DeprecationWarning,
2994 2989 stacklevel=2,
2995 2990 )
2996 2991 # If any of our input transformation (input_transformer_manager or
2997 2992 # prefilter_manager) raises an exception, we store it in this variable
2998 2993 # so that we can display the error after logging the input and storing
2999 2994 # it in the history.
3000 2995 try:
3001 2996 cell = self.transform_cell(raw_cell)
3002 2997 except Exception:
3003 2998 preprocessing_exc_tuple = sys.exc_info()
3004 2999 cell = raw_cell # cell has to exist so it can be stored/logged
3005 3000 else:
3006 3001 preprocessing_exc_tuple = None
3007 3002 else:
3008 3003 if preprocessing_exc_tuple is None:
3009 3004 cell = transformed_cell
3010 3005 else:
3011 3006 cell = raw_cell
3012 3007
3013 3008 # Store raw and processed history
3014 3009 if store_history:
3015 3010 self.history_manager.store_inputs(self.execution_count,
3016 3011 cell, raw_cell)
3017 3012 if not silent:
3018 3013 self.logger.log(cell, raw_cell)
3019 3014
3020 3015 # Display the exception if input processing failed.
3021 3016 if preprocessing_exc_tuple is not None:
3022 3017 self.showtraceback(preprocessing_exc_tuple)
3023 3018 if store_history:
3024 3019 self.execution_count += 1
3025 3020 return error_before_exec(preprocessing_exc_tuple[1])
3026 3021
3027 3022 # Our own compiler remembers the __future__ environment. If we want to
3028 3023 # run code with a separate __future__ environment, use the default
3029 3024 # compiler
3030 3025 compiler = self.compile if shell_futures else self.compiler_class()
3031 3026
3032 3027 _run_async = False
3033 3028
3034 3029 with self.builtin_trap:
3035 3030 cell_name = compiler.cache(cell, self.execution_count, raw_code=raw_cell)
3036 3031
3037 3032 with self.display_trap:
3038 3033 # Compile to bytecode
3039 3034 try:
3040 3035 code_ast = compiler.ast_parse(cell, filename=cell_name)
3041 3036 except self.custom_exceptions as e:
3042 3037 etype, value, tb = sys.exc_info()
3043 3038 self.CustomTB(etype, value, tb)
3044 3039 return error_before_exec(e)
3045 3040 except IndentationError as e:
3046 3041 self.showindentationerror()
3047 3042 return error_before_exec(e)
3048 3043 except (OverflowError, SyntaxError, ValueError, TypeError,
3049 3044 MemoryError) as e:
3050 3045 self.showsyntaxerror()
3051 3046 return error_before_exec(e)
3052 3047
3053 3048 # Apply AST transformations
3054 3049 try:
3055 3050 code_ast = self.transform_ast(code_ast)
3056 3051 except InputRejected as e:
3057 3052 self.showtraceback()
3058 3053 return error_before_exec(e)
3059 3054
3060 3055 # Give the displayhook a reference to our ExecutionResult so it
3061 3056 # can fill in the output value.
3062 3057 self.displayhook.exec_result = result
3063 3058
3064 3059 # Execute the user code
3065 3060 interactivity = "none" if silent else self.ast_node_interactivity
3066 3061
3067 3062 has_raised = await self.run_ast_nodes(code_ast.body, cell_name,
3068 3063 interactivity=interactivity, compiler=compiler, result=result)
3069 3064
3070 3065 self.last_execution_succeeded = not has_raised
3071 3066 self.last_execution_result = result
3072 3067
3073 3068 # Reset this so later displayed values do not modify the
3074 3069 # ExecutionResult
3075 3070 self.displayhook.exec_result = None
3076 3071
3077 3072 if store_history:
3078 3073 # Write output to the database. Does nothing unless
3079 3074 # history output logging is enabled.
3080 3075 self.history_manager.store_output(self.execution_count)
3081 3076 # Each cell is a *single* input, regardless of how many lines it has
3082 3077 self.execution_count += 1
3083 3078
3084 3079 return result
3085 3080
3086 3081 def transform_cell(self, raw_cell):
3087 3082 """Transform an input cell before parsing it.
3088 3083
3089 3084 Static transformations, implemented in IPython.core.inputtransformer2,
3090 3085 deal with things like ``%magic`` and ``!system`` commands.
3091 3086 These run on all input.
3092 3087 Dynamic transformations, for things like unescaped magics and the exit
3093 3088 autocall, depend on the state of the interpreter.
3094 3089 These only apply to single line inputs.
3095 3090
3096 3091 These string-based transformations are followed by AST transformations;
3097 3092 see :meth:`transform_ast`.
3098 3093 """
3099 3094 # Static input transformations
3100 3095 cell = self.input_transformer_manager.transform_cell(raw_cell)
3101 3096
3102 3097 if len(cell.splitlines()) == 1:
3103 3098 # Dynamic transformations - only applied for single line commands
3104 3099 with self.builtin_trap:
3105 3100 # use prefilter_lines to handle trailing newlines
3106 3101 # restore trailing newline for ast.parse
3107 3102 cell = self.prefilter_manager.prefilter_lines(cell) + '\n'
3108 3103
3109 3104 lines = cell.splitlines(keepends=True)
3110 3105 for transform in self.input_transformers_post:
3111 3106 lines = transform(lines)
3112 3107 cell = ''.join(lines)
3113 3108
3114 3109 return cell
3115 3110
3116 3111 def transform_ast(self, node):
3117 3112 """Apply the AST transformations from self.ast_transformers
3118 3113
3119 3114 Parameters
3120 3115 ----------
3121 3116 node : ast.Node
3122 3117 The root node to be transformed. Typically called with the ast.Module
3123 3118 produced by parsing user input.
3124 3119
3125 3120 Returns
3126 3121 -------
3127 3122 An ast.Node corresponding to the node it was called with. Note that it
3128 3123 may also modify the passed object, so don't rely on references to the
3129 3124 original AST.
3130 3125 """
3131 3126 for transformer in self.ast_transformers:
3132 3127 try:
3133 3128 node = transformer.visit(node)
3134 3129 except InputRejected:
3135 3130 # User-supplied AST transformers can reject an input by raising
3136 3131 # an InputRejected. Short-circuit in this case so that we
3137 3132 # don't unregister the transform.
3138 3133 raise
3139 3134 except Exception:
3140 3135 warn("AST transformer %r threw an error. It will be unregistered." % transformer)
3141 3136 self.ast_transformers.remove(transformer)
3142 3137
3143 3138 if self.ast_transformers:
3144 3139 ast.fix_missing_locations(node)
3145 3140 return node
3146 3141
3147 3142 async def run_ast_nodes(
3148 3143 self,
3149 3144 nodelist: ListType[stmt],
3150 3145 cell_name: str,
3151 3146 interactivity="last_expr",
3152 3147 compiler=compile,
3153 3148 result=None,
3154 3149 ):
3155 3150 """Run a sequence of AST nodes. The execution mode depends on the
3156 3151 interactivity parameter.
3157 3152
3158 3153 Parameters
3159 3154 ----------
3160 3155 nodelist : list
3161 3156 A sequence of AST nodes to run.
3162 3157 cell_name : str
3163 3158 Will be passed to the compiler as the filename of the cell. Typically
3164 3159 the value returned by ip.compile.cache(cell).
3165 3160 interactivity : str
3166 3161 'all', 'last', 'last_expr' , 'last_expr_or_assign' or 'none',
3167 3162 specifying which nodes should be run interactively (displaying output
3168 3163 from expressions). 'last_expr' will run the last node interactively
3169 3164 only if it is an expression (i.e. expressions in loops or other blocks
3170 3165 are not displayed) 'last_expr_or_assign' will run the last expression
3171 3166 or the last assignment. Other values for this parameter will raise a
3172 3167 ValueError.
3173 3168
3174 3169 compiler : callable
3175 3170 A function with the same interface as the built-in compile(), to turn
3176 3171 the AST nodes into code objects. Default is the built-in compile().
3177 3172 result : ExecutionResult, optional
3178 3173 An object to store exceptions that occur during execution.
3179 3174
3180 3175 Returns
3181 3176 -------
3182 3177 True if an exception occurred while running code, False if it finished
3183 3178 running.
3184 3179 """
3185 3180 if not nodelist:
3186 3181 return
3187 3182
3188 3183
3189 3184 if interactivity == 'last_expr_or_assign':
3190 3185 if isinstance(nodelist[-1], _assign_nodes):
3191 3186 asg = nodelist[-1]
3192 3187 if isinstance(asg, ast.Assign) and len(asg.targets) == 1:
3193 3188 target = asg.targets[0]
3194 3189 elif isinstance(asg, _single_targets_nodes):
3195 3190 target = asg.target
3196 3191 else:
3197 3192 target = None
3198 3193 if isinstance(target, ast.Name):
3199 3194 nnode = ast.Expr(ast.Name(target.id, ast.Load()))
3200 3195 ast.fix_missing_locations(nnode)
3201 3196 nodelist.append(nnode)
3202 3197 interactivity = 'last_expr'
3203 3198
3204 3199 _async = False
3205 3200 if interactivity == 'last_expr':
3206 3201 if isinstance(nodelist[-1], ast.Expr):
3207 3202 interactivity = "last"
3208 3203 else:
3209 3204 interactivity = "none"
3210 3205
3211 3206 if interactivity == 'none':
3212 3207 to_run_exec, to_run_interactive = nodelist, []
3213 3208 elif interactivity == 'last':
3214 3209 to_run_exec, to_run_interactive = nodelist[:-1], nodelist[-1:]
3215 3210 elif interactivity == 'all':
3216 3211 to_run_exec, to_run_interactive = [], nodelist
3217 3212 else:
3218 3213 raise ValueError("Interactivity was %r" % interactivity)
3219 3214
3220 3215 try:
3221 3216
3222 3217 def compare(code):
3223 3218 is_async = inspect.CO_COROUTINE & code.co_flags == inspect.CO_COROUTINE
3224 3219 return is_async
3225 3220
3226 3221 # refactor that to just change the mod constructor.
3227 3222 to_run = []
3228 3223 for node in to_run_exec:
3229 3224 to_run.append((node, "exec"))
3230 3225
3231 3226 for node in to_run_interactive:
3232 3227 to_run.append((node, "single"))
3233 3228
3234 3229 for node, mode in to_run:
3235 3230 if mode == "exec":
3236 3231 mod = Module([node], [])
3237 3232 elif mode == "single":
3238 3233 mod = ast.Interactive([node])
3239 3234 with compiler.extra_flags(
3240 3235 getattr(ast, "PyCF_ALLOW_TOP_LEVEL_AWAIT", 0x0)
3241 3236 if self.autoawait
3242 3237 else 0x0
3243 3238 ):
3244 3239 code = compiler(mod, cell_name, mode)
3245 3240 asy = compare(code)
3246 3241 if await self.run_code(code, result, async_=asy):
3247 3242 return True
3248 3243
3249 3244 # Flush softspace
3250 3245 if softspace(sys.stdout, 0):
3251 3246 print()
3252 3247
3253 3248 except:
3254 3249 # It's possible to have exceptions raised here, typically by
3255 3250 # compilation of odd code (such as a naked 'return' outside a
3256 3251 # function) that did parse but isn't valid. Typically the exception
3257 3252 # is a SyntaxError, but it's safest just to catch anything and show
3258 3253 # the user a traceback.
3259 3254
3260 3255 # We do only one try/except outside the loop to minimize the impact
3261 3256 # on runtime, and also because if any node in the node list is
3262 3257 # broken, we should stop execution completely.
3263 3258 if result:
3264 3259 result.error_before_exec = sys.exc_info()[1]
3265 3260 self.showtraceback()
3266 3261 return True
3267 3262
3268 3263 return False
3269 3264
3270 3265 async def run_code(self, code_obj, result=None, *, async_=False):
3271 3266 """Execute a code object.
3272 3267
3273 3268 When an exception occurs, self.showtraceback() is called to display a
3274 3269 traceback.
3275 3270
3276 3271 Parameters
3277 3272 ----------
3278 3273 code_obj : code object
3279 3274 A compiled code object, to be executed
3280 3275 result : ExecutionResult, optional
3281 3276 An object to store exceptions that occur during execution.
3282 3277 async_ : Bool (Experimental)
3283 3278 Attempt to run top-level asynchronous code in a default loop.
3284 3279
3285 3280 Returns
3286 3281 -------
3287 3282 False : successful execution.
3288 3283 True : an error occurred.
3289 3284 """
3290 3285 # special value to say that anything above is IPython and should be
3291 3286 # hidden.
3292 3287 __tracebackhide__ = "__ipython_bottom__"
3293 3288 # Set our own excepthook in case the user code tries to call it
3294 3289 # directly, so that the IPython crash handler doesn't get triggered
3295 3290 old_excepthook, sys.excepthook = sys.excepthook, self.excepthook
3296 3291
3297 3292 # we save the original sys.excepthook in the instance, in case config
3298 3293 # code (such as magics) needs access to it.
3299 3294 self.sys_excepthook = old_excepthook
3300 3295 outflag = True # happens in more places, so it's easier as default
3301 3296 try:
3302 3297 try:
3303 3298 if async_:
3304 3299 await eval(code_obj, self.user_global_ns, self.user_ns)
3305 3300 else:
3306 3301 exec(code_obj, self.user_global_ns, self.user_ns)
3307 3302 finally:
3308 3303 # Reset our crash handler in place
3309 3304 sys.excepthook = old_excepthook
3310 3305 except SystemExit as e:
3311 3306 if result is not None:
3312 3307 result.error_in_exec = e
3313 3308 self.showtraceback(exception_only=True)
3314 3309 warn("To exit: use 'exit', 'quit', or Ctrl-D.", stacklevel=1)
3315 3310 except self.custom_exceptions:
3316 3311 etype, value, tb = sys.exc_info()
3317 3312 if result is not None:
3318 3313 result.error_in_exec = value
3319 3314 self.CustomTB(etype, value, tb)
3320 3315 except:
3321 3316 if result is not None:
3322 3317 result.error_in_exec = sys.exc_info()[1]
3323 3318 self.showtraceback(running_compiled_code=True)
3324 3319 else:
3325 3320 outflag = False
3326 3321 return outflag
3327 3322
3328 3323 # For backwards compatibility
3329 3324 runcode = run_code
3330 3325
3331 3326 def check_complete(self, code: str) -> Tuple[str, str]:
3332 3327 """Return whether a block of code is ready to execute, or should be continued
3333 3328
3334 3329 Parameters
3335 3330 ----------
3336 3331 code : string
3337 3332 Python input code, which can be multiline.
3338 3333
3339 3334 Returns
3340 3335 -------
3341 3336 status : str
3342 3337 One of 'complete', 'incomplete', or 'invalid' if source is not a
3343 3338 prefix of valid code.
3344 3339 indent : str
3345 3340 When status is 'incomplete', this is some whitespace to insert on
3346 3341 the next line of the prompt.
3347 3342 """
3348 3343 status, nspaces = self.input_transformer_manager.check_complete(code)
3349 3344 return status, ' ' * (nspaces or 0)
3350 3345
3351 3346 #-------------------------------------------------------------------------
3352 3347 # Things related to GUI support and pylab
3353 3348 #-------------------------------------------------------------------------
3354 3349
3355 3350 active_eventloop = None
3356 3351
3357 3352 def enable_gui(self, gui=None):
3358 3353 raise NotImplementedError('Implement enable_gui in a subclass')
3359 3354
3360 3355 def enable_matplotlib(self, gui=None):
3361 3356 """Enable interactive matplotlib and inline figure support.
3362 3357
3363 3358 This takes the following steps:
3364 3359
3365 3360 1. select the appropriate eventloop and matplotlib backend
3366 3361 2. set up matplotlib for interactive use with that backend
3367 3362 3. configure formatters for inline figure display
3368 3363 4. enable the selected gui eventloop
3369 3364
3370 3365 Parameters
3371 3366 ----------
3372 3367 gui : optional, string
3373 3368 If given, dictates the choice of matplotlib GUI backend to use
3374 3369 (should be one of IPython's supported backends, 'qt', 'osx', 'tk',
3375 3370 'gtk', 'wx' or 'inline'), otherwise we use the default chosen by
3376 3371 matplotlib (as dictated by the matplotlib build-time options plus the
3377 3372 user's matplotlibrc configuration file). Note that not all backends
3378 3373 make sense in all contexts, for example a terminal ipython can't
3379 3374 display figures inline.
3380 3375 """
3381 3376 from IPython.core import pylabtools as pt
3382 3377 from matplotlib_inline.backend_inline import configure_inline_support
3383 3378 gui, backend = pt.find_gui_and_backend(gui, self.pylab_gui_select)
3384 3379
3385 3380 if gui != 'inline':
3386 3381 # If we have our first gui selection, store it
3387 3382 if self.pylab_gui_select is None:
3388 3383 self.pylab_gui_select = gui
3389 3384 # Otherwise if they are different
3390 3385 elif gui != self.pylab_gui_select:
3391 3386 print('Warning: Cannot change to a different GUI toolkit: %s.'
3392 3387 ' Using %s instead.' % (gui, self.pylab_gui_select))
3393 3388 gui, backend = pt.find_gui_and_backend(self.pylab_gui_select)
3394 3389
3395 3390 pt.activate_matplotlib(backend)
3396 3391 configure_inline_support(self, backend)
3397 3392
3398 3393 # Now we must activate the gui pylab wants to use, and fix %run to take
3399 3394 # plot updates into account
3400 3395 self.enable_gui(gui)
3401 3396 self.magics_manager.registry['ExecutionMagics'].default_runner = \
3402 3397 pt.mpl_runner(self.safe_execfile)
3403 3398
3404 3399 return gui, backend
3405 3400
3406 3401 def enable_pylab(self, gui=None, import_all=True, welcome_message=False):
3407 3402 """Activate pylab support at runtime.
3408 3403
3409 3404 This turns on support for matplotlib, preloads into the interactive
3410 3405 namespace all of numpy and pylab, and configures IPython to correctly
3411 3406 interact with the GUI event loop. The GUI backend to be used can be
3412 3407 optionally selected with the optional ``gui`` argument.
3413 3408
3414 3409 This method only adds preloading the namespace to InteractiveShell.enable_matplotlib.
3415 3410
3416 3411 Parameters
3417 3412 ----------
3418 3413 gui : optional, string
3419 3414 If given, dictates the choice of matplotlib GUI backend to use
3420 3415 (should be one of IPython's supported backends, 'qt', 'osx', 'tk',
3421 3416 'gtk', 'wx' or 'inline'), otherwise we use the default chosen by
3422 3417 matplotlib (as dictated by the matplotlib build-time options plus the
3423 3418 user's matplotlibrc configuration file). Note that not all backends
3424 3419 make sense in all contexts, for example a terminal ipython can't
3425 3420 display figures inline.
3426 3421 import_all : optional, bool, default: True
3427 3422 Whether to do `from numpy import *` and `from pylab import *`
3428 3423 in addition to module imports.
3429 3424 welcome_message : deprecated
3430 3425 This argument is ignored, no welcome message will be displayed.
3431 3426 """
3432 3427 from IPython.core.pylabtools import import_pylab
3433 3428
3434 3429 gui, backend = self.enable_matplotlib(gui)
3435 3430
3436 3431 # We want to prevent the loading of pylab to pollute the user's
3437 3432 # namespace as shown by the %who* magics, so we execute the activation
3438 3433 # code in an empty namespace, and we update *both* user_ns and
3439 3434 # user_ns_hidden with this information.
3440 3435 ns = {}
3441 3436 import_pylab(ns, import_all)
3442 3437 # warn about clobbered names
3443 3438 ignored = {"__builtins__"}
3444 3439 both = set(ns).intersection(self.user_ns).difference(ignored)
3445 3440 clobbered = [ name for name in both if self.user_ns[name] is not ns[name] ]
3446 3441 self.user_ns.update(ns)
3447 3442 self.user_ns_hidden.update(ns)
3448 3443 return gui, backend, clobbered
3449 3444
3450 3445 #-------------------------------------------------------------------------
3451 3446 # Utilities
3452 3447 #-------------------------------------------------------------------------
3453 3448
3454 3449 def var_expand(self, cmd, depth=0, formatter=DollarFormatter()):
3455 3450 """Expand python variables in a string.
3456 3451
3457 3452 The depth argument indicates how many frames above the caller should
3458 3453 be walked to look for the local namespace where to expand variables.
3459 3454
3460 3455 The global namespace for expansion is always the user's interactive
3461 3456 namespace.
3462 3457 """
3463 3458 ns = self.user_ns.copy()
3464 3459 try:
3465 3460 frame = sys._getframe(depth+1)
3466 3461 except ValueError:
3467 3462 # This is thrown if there aren't that many frames on the stack,
3468 3463 # e.g. if a script called run_line_magic() directly.
3469 3464 pass
3470 3465 else:
3471 3466 ns.update(frame.f_locals)
3472 3467
3473 3468 try:
3474 3469 # We have to use .vformat() here, because 'self' is a valid and common
3475 3470 # name, and expanding **ns for .format() would make it collide with
3476 3471 # the 'self' argument of the method.
3477 3472 cmd = formatter.vformat(cmd, args=[], kwargs=ns)
3478 3473 except Exception:
3479 3474 # if formatter couldn't format, just let it go untransformed
3480 3475 pass
3481 3476 return cmd
3482 3477
3483 3478 def mktempfile(self, data=None, prefix='ipython_edit_'):
3484 3479 """Make a new tempfile and return its filename.
3485 3480
3486 3481 This makes a call to tempfile.mkstemp (created in a tempfile.mkdtemp),
3487 3482 but it registers the created filename internally so ipython cleans it up
3488 3483 at exit time.
3489 3484
3490 3485 Optional inputs:
3491 3486
3492 3487 - data(None): if data is given, it gets written out to the temp file
3493 3488 immediately, and the file is closed again."""
3494 3489
3495 3490 dir_path = Path(tempfile.mkdtemp(prefix=prefix))
3496 3491 self.tempdirs.append(dir_path)
3497 3492
3498 3493 handle, filename = tempfile.mkstemp(".py", prefix, dir=str(dir_path))
3499 3494 os.close(handle) # On Windows, there can only be one open handle on a file
3500 3495
3501 3496 file_path = Path(filename)
3502 3497 self.tempfiles.append(file_path)
3503 3498
3504 3499 if data:
3505 3500 file_path.write_text(data, encoding="utf-8")
3506 3501 return filename
3507 3502
3508 3503 def ask_yes_no(self, prompt, default=None, interrupt=None):
3509 3504 if self.quiet:
3510 3505 return True
3511 3506 return ask_yes_no(prompt,default,interrupt)
3512 3507
3513 3508 def show_usage(self):
3514 3509 """Show a usage message"""
3515 3510 page.page(IPython.core.usage.interactive_usage)
3516 3511
3517 3512 def extract_input_lines(self, range_str, raw=False):
3518 3513 """Return as a string a set of input history slices.
3519 3514
3520 3515 Parameters
3521 3516 ----------
3522 3517 range_str : str
3523 3518 The set of slices is given as a string, like "~5/6-~4/2 4:8 9",
3524 3519 since this function is for use by magic functions which get their
3525 3520 arguments as strings. The number before the / is the session
3526 3521 number: ~n goes n back from the current session.
3527 3522
3528 3523 If empty string is given, returns history of current session
3529 3524 without the last input.
3530 3525
3531 3526 raw : bool, optional
3532 3527 By default, the processed input is used. If this is true, the raw
3533 3528 input history is used instead.
3534 3529
3535 3530 Notes
3536 3531 -----
3537 3532 Slices can be described with two notations:
3538 3533
3539 3534 * ``N:M`` -> standard python form, means including items N...(M-1).
3540 3535 * ``N-M`` -> include items N..M (closed endpoint).
3541 3536 """
3542 3537 lines = self.history_manager.get_range_by_str(range_str, raw=raw)
3543 3538 text = "\n".join(x for _, _, x in lines)
3544 3539
3545 3540 # Skip the last line, as it's probably the magic that called this
3546 3541 if not range_str:
3547 3542 if "\n" not in text:
3548 3543 text = ""
3549 3544 else:
3550 3545 text = text[: text.rfind("\n")]
3551 3546
3552 3547 return text
3553 3548
3554 3549 def find_user_code(self, target, raw=True, py_only=False, skip_encoding_cookie=True, search_ns=False):
3555 3550 """Get a code string from history, file, url, or a string or macro.
3556 3551
3557 3552 This is mainly used by magic functions.
3558 3553
3559 3554 Parameters
3560 3555 ----------
3561 3556 target : str
3562 3557 A string specifying code to retrieve. This will be tried respectively
3563 3558 as: ranges of input history (see %history for syntax), url,
3564 3559 corresponding .py file, filename, or an expression evaluating to a
3565 3560 string or Macro in the user namespace.
3566 3561
3567 3562 If empty string is given, returns complete history of current
3568 3563 session, without the last line.
3569 3564
3570 3565 raw : bool
3571 3566 If true (default), retrieve raw history. Has no effect on the other
3572 3567 retrieval mechanisms.
3573 3568
3574 3569 py_only : bool (default False)
3575 3570 Only try to fetch python code, do not try alternative methods to decode file
3576 3571 if unicode fails.
3577 3572
3578 3573 Returns
3579 3574 -------
3580 3575 A string of code.
3581 3576 ValueError is raised if nothing is found, and TypeError if it evaluates
3582 3577 to an object of another type. In each case, .args[0] is a printable
3583 3578 message.
3584 3579 """
3585 3580 code = self.extract_input_lines(target, raw=raw) # Grab history
3586 3581 if code:
3587 3582 return code
3588 3583 try:
3589 3584 if target.startswith(('http://', 'https://')):
3590 3585 return openpy.read_py_url(target, skip_encoding_cookie=skip_encoding_cookie)
3591 3586 except UnicodeDecodeError as e:
3592 3587 if not py_only :
3593 3588 # Deferred import
3594 3589 from urllib.request import urlopen
3595 3590 response = urlopen(target)
3596 3591 return response.read().decode('latin1')
3597 3592 raise ValueError(("'%s' seem to be unreadable.") % target) from e
3598 3593
3599 3594 potential_target = [target]
3600 3595 try :
3601 3596 potential_target.insert(0,get_py_filename(target))
3602 3597 except IOError:
3603 3598 pass
3604 3599
3605 3600 for tgt in potential_target :
3606 3601 if os.path.isfile(tgt): # Read file
3607 3602 try :
3608 3603 return openpy.read_py_file(tgt, skip_encoding_cookie=skip_encoding_cookie)
3609 3604 except UnicodeDecodeError as e:
3610 3605 if not py_only :
3611 3606 with io_open(tgt,'r', encoding='latin1') as f :
3612 3607 return f.read()
3613 3608 raise ValueError(("'%s' seem to be unreadable.") % target) from e
3614 3609 elif os.path.isdir(os.path.expanduser(tgt)):
3615 3610 raise ValueError("'%s' is a directory, not a regular file." % target)
3616 3611
3617 3612 if search_ns:
3618 3613 # Inspect namespace to load object source
3619 3614 object_info = self.object_inspect(target, detail_level=1)
3620 3615 if object_info['found'] and object_info['source']:
3621 3616 return object_info['source']
3622 3617
3623 3618 try: # User namespace
3624 3619 codeobj = eval(target, self.user_ns)
3625 3620 except Exception as e:
3626 3621 raise ValueError(("'%s' was not found in history, as a file, url, "
3627 3622 "nor in the user namespace.") % target) from e
3628 3623
3629 3624 if isinstance(codeobj, str):
3630 3625 return codeobj
3631 3626 elif isinstance(codeobj, Macro):
3632 3627 return codeobj.value
3633 3628
3634 3629 raise TypeError("%s is neither a string nor a macro." % target,
3635 3630 codeobj)
3636 3631
3637 3632 def _atexit_once(self):
3638 3633 """
3639 3634 At exist operation that need to be called at most once.
3640 3635 Second call to this function per instance will do nothing.
3641 3636 """
3642 3637
3643 3638 if not getattr(self, "_atexit_once_called", False):
3644 3639 self._atexit_once_called = True
3645 3640 # Clear all user namespaces to release all references cleanly.
3646 3641 self.reset(new_session=False)
3647 3642 # Close the history session (this stores the end time and line count)
3648 3643 # this must be *before* the tempfile cleanup, in case of temporary
3649 3644 # history db
3650 3645 self.history_manager.end_session()
3651 3646 self.history_manager = None
3652 3647
3653 3648 #-------------------------------------------------------------------------
3654 3649 # Things related to IPython exiting
3655 3650 #-------------------------------------------------------------------------
3656 3651 def atexit_operations(self):
3657 3652 """This will be executed at the time of exit.
3658 3653
3659 3654 Cleanup operations and saving of persistent data that is done
3660 3655 unconditionally by IPython should be performed here.
3661 3656
3662 3657 For things that may depend on startup flags or platform specifics (such
3663 3658 as having readline or not), register a separate atexit function in the
3664 3659 code that has the appropriate information, rather than trying to
3665 3660 clutter
3666 3661 """
3667 3662 self._atexit_once()
3668 3663
3669 3664 # Cleanup all tempfiles and folders left around
3670 3665 for tfile in self.tempfiles:
3671 3666 try:
3672 3667 tfile.unlink()
3673 3668 self.tempfiles.remove(tfile)
3674 3669 except FileNotFoundError:
3675 3670 pass
3676 3671 del self.tempfiles
3677 3672 for tdir in self.tempdirs:
3678 3673 try:
3679 3674 tdir.rmdir()
3680 3675 self.tempdirs.remove(tdir)
3681 3676 except FileNotFoundError:
3682 3677 pass
3683 3678 del self.tempdirs
3684 3679
3685 3680
3686 3681 def cleanup(self):
3687 3682 self.restore_sys_module_state()
3688 3683
3689 3684
3690 3685 # Overridden in terminal subclass to change prompts
3691 3686 def switch_doctest_mode(self, mode):
3692 3687 pass
3693 3688
3694 3689
3695 3690 class InteractiveShellABC(metaclass=abc.ABCMeta):
3696 3691 """An abstract base class for InteractiveShell."""
3697 3692
3698 3693 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