In [1]:

    

%load_ext autoreload
%autoreload 2


    

In [2]:

    

import sys
sys.path.append("..")


    

In [3]:

    

from optimus import Optimus


    

In [11]:

    

op= Optimus(verbose=True, server= True)


    

    




Just check that Spark and all necessary environments vars are present...
-----
SPARK_HOME=C:\opt\spark\spark-2.3.1-bin-hadoop2.7
HADOOP_HOME=C:\opt\spark\spark-2.3.1-bin-hadoop2.7
You don't have PYSPARK_PYTHON set
You don't have PYSPARK_DRIVER_PYTHON set
JAVA_HOME=C:\Program Files\Java\jdk1.8.0_181
Pyarrow Installed
-----
Starting or getting SparkSession and SparkContext...

                             ____        __  _                     
                            / __ \____  / /_(_)___ ___  __  _______
                           / / / / __ \/ __/ / __ `__ \/ / / / ___/
                          / /_/ / /_/ / /_/ / / / / / / /_/ (__  ) 
                          \____/ .___/\__/_/_/ /_/ /_/\__,_/____/  
                              /_/                                  
                              
Transform and Roll out...
Starting Optimus Server...
Server started with process id 9544
Optimus successfully imported. Have fun :).

In [12]:

    

from optimus.server.server import Server
s = Server()
s.start()


    

    




Server seems to be running with process id 9544

In [13]:

    

s.stop()


    

    




Optimus Server stopped

In [ ]: